JitsuVerifiedFeatured

List the Jitsu workspaces the authenticated user can access (paginated, max 100 per page). Returns { workspaces, total, limit, offset, hasMore }; page with `offset` while `hasMore` is true. Use a workspace `id` as the `workspaceId` argument to other tools.

List configuration resources of a given type in a workspace. type ∈ {destination, stream, function, service, custom-image, domain, notification, connection}. Use "connection" for connections (links between streams/services and destinations).

Get a single configuration resource by id. type ∈ {destination, stream, function, service, custom-image, domain, notification, connection}.

JSON Schema describing the payload for creating/updating a resource. type ∈ {destination, stream, function, service, custom-image, domain, notification, connection}. Use `subtype` to narrow: a destination/service kind (e.g. "postgres"), or for "connection" the connection kind ("sync", or a destination type for push connections).

Create a configuration resource. type ∈ {destination, stream, function, service, custom-image, domain, notification, connection}. `data` must match get_resource_schema for the type. For "connection", `data` is the connection body: { fromId, toId, type: "push"|"sync", data }.

Update a configuration resource by id (merged into the existing object). type ∈ {destination, stream, function, service, custom-image, domain, notification, connection}. For "connection", `data` is the connection body and the link is upserted by id.

Delete a configuration resource by id (soft delete). type ∈ {destination, stream, function, service, custom-image, domain, notification, connection}.

List the sources (actors) you can pass as `source` to query_events, for a workspace. Optionally narrow by `type`: "incoming" → streams; "function"/"bulker_batch"/"bulker_stream" → connections, destinations, profile builders; "dead-letter" adds the "all" sentinel.

Read recent event-log records for a workspace. type ∈ {incoming, function, bulker_batch, bulker_stream, dead-letter}. `source` filters to one actor (a stream id for "incoming"; a connection id for "function"/"bulker_*"; any actor or "all" for "dead-letter"). Omit `source` (or pass "all") to query across ALL the workspace's sources. Use list_event_sources to discover ids. Results are newest-first, capped by `limit`.

Schedule a sync (a connection of type "sync") to run immediately. Returns the new `taskId`; poll list_sync_tasks with it for status and get_sync_logs for output. If a task is already running the call fails and returns `runningTask` — pass ignoreRunning=true to cancel it and start anyway. fullSync=true drops the saved cursor and re-syncs from scratch.

Cancel a running sync task. Cancellation is asynchronous — poll list_sync_tasks until the task status becomes CANCELLED.

Up to 50 most recent sync tasks in a workspace, newest first. Filter by `syncId`, a single `taskId` (returns `task`), `status` (RUNNING, SUCCESS, PARTIAL, FAILED, CANCELLED, SKIPPED), and a `from`/`to` time window.

Log records of a sync task, newest first (default 200 records, max 5000).

JSON schema of a connector package's credentials (the `credentials` field of a service). ASYNC: the first call starts a fetch on the sync controller and returns `{ ok: false, pending: true }` — call again (every few seconds) until `ok: true` and `specs` is set, or `error` is returned. force=true bypasses the cache.

Ask the connector of an existing service to list its available streams (the catalog used to configure a sync). ASYNC: returns `{ ok: false, pending: true }` while running — call again (every few seconds) until `ok: true` and `catalog` is set. refresh=true re-fetches an already-cached catalog; force=true ignores the cache entirely.

Start an async credentials check for an existing service (source) using its stored config. Returns `{ pending: true, storageKey }` — poll get_source_check_result with the storageKey until it resolves. For destinations use test_connection instead (synchronous).

Poll the result of check_source_credentials: `{ ok: true }` on success, `{ ok: false, error }` on failure, `{ ok: false, pending: true }` while still running.

The saved incremental cursor of a sync, keyed by stream (empty object if none saved).

Delete the saved cursor of a sync so the next run re-syncs from scratch. Pass `stream` to reset a single stream, omit it to reset all. Fails while the sync is running. Returns the remaining state.

Synchronously test destination credentials via bulker. Pass `id` to test an existing destination as stored, or `config` (see get_resource_schema) to test an unsaved config — masked secrets in `config` are resolved from the object referenced by `config.id`. For services (sources) use check_source_credentials instead.

Run a transformation function against a sample event on the workspace's functions server and return the result, logs, and store mutations. `code` omitted → the stored function's draft/code is used. Nothing is persisted; events are not sent anywhere.

Run a profile-builder function against sample events and return the computed profile, logs, and store mutations. `code`/`settings` omitted → loaded from the stored profile builder. Nothing is persisted.

Event counts per period, connection, stream, destination, and status (success/dropped/error) for a workspace. Defaults to the last month with day granularity.

Number of distinct source→destination pairs with at least one successful sync task in the period (defaults to the last month).

Build progress of a profile-builder version: status (ready/building/unknown), processed/total users, and speed. `version` omitted → the current version.