Skip to content
Elaichi Elaichi

Database

Sequin Stream

Connect Sequin Stream once and hand every teammate a governed MCP endpoint with 27 tools ready to call from Claude, ChatGPT, Cursor, or any MCP client, inside the same permissions they already have, with every call checked and logged.

Sequin Stream

Automations & dashboards

From answering questions to doing the work

A person no longer has to ask. A trigger starts the work, inside the same permissions and the same audit log as everything else. Automations and live dashboards ship on the Black plan.

Automations

Put Sequin Stream work on a schedule.

A trigger starts a sequence of steps: call a Sequin Stream tool, transform the result, branch, wait, and ask a person when it matters.

Sequin Stream digest

Run 418 · started 2 minutes ago · on behalf of Emma Laurent

  1. Schedule

    Every weekday at 08:00

    0.2s
  2. Fetch backfills

    Sequin Stream

    1.4s
  3. Group by owner

    Transform

    0.1s
  4. Draft the digest

    Agent step

    Ran with 4 tools, returned a structured summary

    6.2s
  5. Approve the digest

    Needs approval

    Assigned to Michael Brennan

    Approve
  6. Post the digest

    Sequin Stream

    Queued

Collections and dashboards

Report on Sequin Stream without asking.

Collections hold your own data, written by an automation and read by a dashboard that refreshes on a schedule.

Sequin Stream health

Refreshed 4 minutes ago · every 15 minutes · from the backfills collection

Live

Backfills

1,284 ↓ 12%

Backfillses

96 ↓ 8%

Needs attention

3 ↑ 2

Updated this week

412 ↑ 9%

Backfills created

Last 14 days

By workspace

Share of activity

Engineering 34%

Product 27%

Support 21%

Sales 18%

AI tools

Sequin Stream tools for your AI agents

27 tools are ready to call through Elaichi's MCP endpoint the moment you connect Sequin Stream, governed by the same roles, restrictions, and audit log as everything else in Elaichi.

create_a_sequinstream_backfill

Create a new backfill for a Sequin sink, starting it in the active state. Returns: id, state, sink_consumer, rows_initial_count, rows_processed_count, rows_ingested_count, inserted_at, updated_at, canceled_at, completed_at, table, sort_column. Required: sink_id_or_name. Specify table when the sink is configured to stream all tables in a schema.

delete_a_sequinstream_backfill_by_id

Delete a Sequin backfill by id. Returns: id, deleted. Required: sink_id_or_name, id.

get_single_sequinstream_backfill_by_id

Get details of a specific Sequin backfill by id. Returns: id, state, sink_consumer, rows_ingested_count, rows_processed_count, rows_initial_count, inserted_at, updated_at, canceled_at, completed_at, table, sort_column. Required: sink_id_or_name, id.

list_all_sequinstream_backfills

List all backfills for a Sequin sink. Returns: id, state, sink_consumer, rows_ingested_count, rows_processed_count, rows_initial_count, inserted_at, updated_at, canceled_at, completed_at, table, sort_column. Required: sink_id_or_name.

update_a_sequinstream_backfill_by_id

Update the state of a Sequin backfill, for example to cancel an active backfill. Returns: id, state, sink_consumer, rows_ingested_count, rows_processed_count, rows_initial_count, inserted_at, updated_at, canceled_at, completed_at, table, sort_column. Required: sink_id_or_name, id.

create_a_sequinstream_http_endpoint

Create a new HTTP endpoint in Sequin (regular HTTP, webhook.site, or local type). Returns: id, name, url, headers, encrypted_headers (response fields vary by endpoint type). Required: name.

delete_a_sequinstream_http_endpoint_by_id

Delete an HTTP endpoint in Sequin by id. Returns: id, deleted.

get_single_sequinstream_http_endpoint_by_id

Get details for a specific HTTP endpoint in Sequin by id. Returns: id, name, url, headers, encrypted_headers (fields vary by endpoint type: regular, webhook.site, or local).

list_all_sequinstream_http_endpoints

List all HTTP endpoints in Sequin. Returns: id, name, url, headers, encrypted_headers per endpoint (fields vary by type: regular, webhook.site, or local).

update_a_sequinstream_http_endpoint_by_id

Update an existing HTTP endpoint in Sequin by id. Returns: id, name, url, headers, encrypted_headers (fields vary by endpoint type: regular, webhook.site, or local).

create_a_sequinstream_postgres_database

Create a Sequin Postgres database connection with a replication slot. Returns: id, name, hostname, port, database, ssl, ipv6, use_local_tunnel, replication_slots. Required: name, replication_slots (exactly one slot). Supply either url or individual connection params (hostname, database, username, password).

delete_a_sequinstream_postgres_database_by_id

Delete a Sequin Postgres database connection and its associated replication slot by id. Returns: success, id. Required: id. Fails with a validation error if the database has associated sink consumers or WAL pipelines.

get_single_sequinstream_postgres_database_by_id

Get a single Sequin Postgres database connection by id. Returns: id, name, hostname, port, database, username, ssl, ipv6, use_local_tunnel, pool_size, queue_interval, queue_target, replication_slots. Required: id.

list_all_sequinstream_postgres_databases

List all Sequin Postgres database connections in your account. Returns: id, name, hostname, port, database, username, ssl, ipv6, use_local_tunnel, pool_size, queue_interval, queue_target, replication_slots.

update_a_sequinstream_postgres_database_by_id

Update an existing Sequin Postgres database connection by id. Returns: id, name, hostname, port, database, ssl, ipv6, use_local_tunnel, replication_slots. Required: id. When updating replication_slots, supply exactly one slot object including its id.

create_a_sequinstream_sink_consumer

Create a new sink consumer in Sequin. Returns: id, name, status, database, source, destination, actions, batch_size, load_shedding_policy, health, and more. Required: name, database, destination.

delete_a_sequinstream_sink_consumer_by_id

Delete a Sequin sink consumer by id. Returns an empty 204 response on success.

get_single_sequinstream_sink_consumer_by_id

Get a single Sequin sink consumer by id. Returns: id, name, status, database, source, destination, actions, batch_size, load_shedding_policy, message_grouping, health, and more.

list_all_sequinstream_sink_consumers

List all Sequin sink consumers. Returns per record: id, name, status, database, source, destination, actions, batch_size, load_shedding_policy, and health.

update_a_sequinstream_sink_consumer_by_id

Update an existing Sequin sink consumer by id. Returns: id, name, status, database, source, destination, actions, batch_size, load_shedding_policy, message_grouping, health, and more.

update_a_sequinstream_http_pull_consumer_by_id

Acknowledge messages in a Sequin http_pull_consumer, marking them as processed and removing them from the stream. Returns: success. Required: ack_ids.

list_all_sequinstream_http_pull_consumers

Receive next messages from a Sequin http_pull_consumer stream. Returns: ack_id, record, action, changes, and metadata per message. Use batch_size to request multiple messages at once and wait_for to enable long polling.

create_a_sequinstream_postgres_database_table_refresh

Trigger a table refresh for a Sequin PostgreSQL database, causing Sequin to re-sync its internal list of available tables from the upstream database. Returns an empty 204 response on success. Required: database_id_or_name.

create_a_sequinstream_postgres_database_connection_test

Test the connection for an existing Sequin Postgres database, verifying network reachability, authentication, connect permissions, and replication slot validity. Returns an empty 204 response on success. Required: database_id_or_name.

list_all_sequinstream_http_pull_consumer_messages

Receive pending messages from a Sequin HTTP pull consumer. Returns messages including ack_id and data (the record payload with metadata). Required: consumer_id_or_name.

create_a_sequinstream_http_pull_consumer_ack

Acknowledge one or more messages for a Sequin HTTP pull consumer, marking them as successfully processed and removing them from redelivery. Required: consumer_id_or_name, ack_ids. Returns an empty 204 response on success.

create_a_sequinstream_http_pull_consumer_nack

Negatively acknowledge (nack) messages for a Sequin HTTP pull consumer, signaling that they should be requeued for redelivery. Returns an empty 204 response on success. Required: consumer_id_or_name.

How it works

From Sequin Stream account to governed MCP endpoint

Connect

Link a Sequin Stream account through Elaichi's hosted connect flow. Credentials are vaulted, so nobody, including the AI, ever sees them.

Compose

The connection becomes a toolbox instantly. Curate which Sequin Stream tools are exposed, rename them, or freeze arguments.

Authorize

Point Claude, ChatGPT, Cursor, or any MCP client at the one Elaichi endpoint and sign in with OAuth, governed by roles, restrictions, and audit logs.

Put your agents to work in the tools you already use

Start a 14-day Gold trial. Connect a product, curate a toolbox, and paste a governed MCP endpoint into Claude, ChatGPT, or Cursor in minutes.