Salesforce

Use the @bijection/connectors/salesforce entrypoint to declare Salesforce resources.

Availability

This page describes the pinned source package. Published availability is unestablished for this artifact. Source build and package availability.

Resources and modes

Resource	Mode	Description
Object records	`incremental`	Ordered walk with deletion windows
Object records	`discovery`	Discovery and detail reads
Platform events	`platform`	CometD
Platform events	`pubsub`	Pub/Sub API
Change data capture	`cdc`	CometD
Change data capture	`pubsub`	Pub/Sub API

Declare a resource in application code, then bind deployment-specific settings and credentials. See typed resources, connections and source inspection.

Object records

incremental: Ordered walk with deletion windows

The following example matches configuration standard.

import { salesforce } from "@bijection/connectors/salesforce";
import { v } from "bijection/values";
export const accounts = salesforce.objects.incremental({
  object: "Account",
  schema: { Id: v.string(), Name: v.string() },
});

Inferred record types

{
  "Id": string;
  "Name": string;
}

Configuration: standard

Case: salesforce/objects/incremental/standard. Connection and resource configuration are declared by this exact case. Credential kind: salesforce. Keep credential material in the private credential inventory.

Setting	Type	Required	Owner
`instance`	string	Yes	Shared connection

Provider setup requirements:

[
  {
    "key": "instance",
    "supplier": "account",
    "label": "Salesforce My Domain",
    "prefix": "https://",
    "suffix": ".my.salesforce.com",
    "fills": "base_url"
  }
]

Complete configuration contract

{
  "setup": [
    {
      "key": "instance",
      "supplier": "account",
      "label": "Salesforce My Domain",
      "prefix": "https://",
      "suffix": ".my.salesforce.com",
      "fills": "base_url"
    }
  ],
  "resource": {
    "access": {},
    "defaults": {},
    "connector": "salesforce",
    "output": {
      "kind": "single",
      "collection": "records"
    },
    "credential_kind": "salesforce",
    "connection_fields": [
      "instance"
    ],
    "address": {
      "kind": "setup",
      "field": "instance",
      "prefix": "https://",
      "suffix": ".my.salesforce.com"
    }
  },
  "connection_setup": {
    "type": "object",
    "value": {
      "instance": {
        "fieldType": {
          "type": "string"
        },
        "optional": false
      }
    }
  },
  "execution": null
}

Native admission analysis is available for this exact declaration. Collection: records

Contract	Meaning
Initial	Enumeration of observed records
Changes	Current record read after a change indication
Deletions	Explicit deletion evidence
Resume	Opaque cursor
Gap	Explicit repair required after a gap
Retention	Unspecified

Complete native profile

{
  "movement": {
    "exchanges": {},
    "nativeInputLimitBytes": "0",
    "steps": [
      {
        "id": "acquire.1",
        "inputs": [],
        "action": {
          "operation": "acquire",
          "subject": "native input",
          "limitBytes": "0"
        }
      },
      {
        "id": "retain.1",
        "inputs": [
          "acquire.1"
        ],
        "action": {
          "operation": "retain",
          "subject": "acquisition evidence",
          "reason": "recovery",
          "release": "acquisition_custody"
        }
      },
      {
        "id": "interpret.1",
        "inputs": [
          "retain.1"
        ],
        "action": {
          "operation": "interpret",
          "subject": "acquired input",
          "produces": "records"
        }
      },
      {
        "id": "materialize.1",
        "inputs": [
          "interpret.1"
        ],
        "action": {
          "operation": "materialize",
          "subject": "source rows",
          "reason": "serving",
          "release": "replacement"
        }
      },
      {
        "id": "publish.1",
        "inputs": [
          "materialize.1"
        ],
        "action": {
          "operation": "publish",
          "subject": "source rows",
          "visibility": "with_acquisition"
        }
      }
    ]
  },
  "initial": "enumeration",
  "changes": "current_state_after_change",
  "deletions": "explicit_events",
  "resume": "opaque_cursor",
  "retentionMs": null,
  "gap": "explicit_repair",
  "limits": {
    "exchange_evidence_bytes": "524288",
    "publication_page_records": "128",
    "record_fields": "32"
  },
  "restrictions": [
    "Current rows in SystemModstamp order, bounded by the delete log's latestDateCovered; queryAll tombstones and getDeleted windows are the only deletions, and an expired delete log is a gap"
  ],
  "commands": {}
}

Commands, occurrences and artifacts

{
  "records": {
    "records": {
      "protocol": "record_observation",
      "coverage": "records",
      "consistency": "observations",
      "atomicity": "record",
      "history": "observations",
      "recordRefresh": false,
      "reconciliation": false,
      "notifications": false,
      "snapshotMaxRows": null,
      "profile": {
        "movement": {
          "exchanges": {},
          "nativeInputLimitBytes": "0",
          "steps": [
            {
              "id": "acquire.1",
              "inputs": [],
              "action": {
                "operation": "acquire",
                "subject": "native input",
                "limitBytes": "0"
              }
            },
            {
              "id": "retain.1",
              "inputs": [
                "acquire.1"
              ],
              "action": {
                "operation": "retain",
                "subject": "acquisition evidence",
                "reason": "recovery",
                "release": "acquisition_custody"
              }
            },
            {
              "id": "interpret.1",
              "inputs": [
                "retain.1"
              ],
              "action": {
                "operation": "interpret",
                "subject": "acquired input",
                "produces": "records"
              }
            },
            {
              "id": "materialize.1",
              "inputs": [
                "interpret.1"
              ],
              "action": {
                "operation": "materialize",
                "subject": "source rows",
                "reason": "serving",
                "release": "replacement"
              }
            },
            {
              "id": "publish.1",
              "inputs": [
                "materialize.1"
              ],
              "action": {
                "operation": "publish",
                "subject": "source rows",
                "visibility": "with_acquisition"
              }
            }
          ]
        },
        "initial": "enumeration",
        "changes": "current_state_after_change",
        "deletions": "explicit_events",
        "resume": "opaque_cursor",
        "retentionMs": null,
        "gap": "explicit_repair",
        "limits": {
          "exchange_evidence_bytes": "524288",
          "publication_page_records": "128",
          "record_fields": "32"
        },
        "restrictions": [
          "Current rows in SystemModstamp order, bounded by the delete log's latestDateCovered; queryAll tombstones and getDeleted windows are the only deletions, and an expired delete log is a gap"
        ],
        "commands": {}
      }
    }
  },
  "occurrences": null,
  "artifacts": {
    "raw_archive": false,
    "native_file_transfer_limit_bytes": null,
    "external_versions": false,
    "files": {}
  },
  "commands": {}
}

Recorded checks

Requirement	Scope	Evidence	Result
page-publication-recovery	{“kind”:“collection”,“name”:“records”}	No case-scoped check receipt is attached. The native reader’s statement, row, CSV and Pub/Sub decoding unit tests (connector_documents salesforce::records, connector_streams pubsub_api) are not scenario runs, and no Salesforce org has run these recipes.	Execution result unavailable

Hosted qualification: unestablished for this catalog configuration. Installed connections report their own identity, authority and current status.

Configuration: bulk

Case: salesforce/objects/incremental/bulk. Connection and resource configuration are declared by this exact case. Credential kind: salesforce. Keep credential material in the private credential inventory.

Setting	Type	Required	Owner
`instance`	string	Yes	Shared connection

Provider setup requirements:

[
  {
    "key": "instance",
    "supplier": "account",
    "label": "Salesforce My Domain",
    "prefix": "https://",
    "suffix": ".my.salesforce.com",
    "fills": "base_url"
  }
]

Complete configuration contract

{
  "setup": [
    {
      "key": "instance",
      "supplier": "account",
      "label": "Salesforce My Domain",
      "prefix": "https://",
      "suffix": ".my.salesforce.com",
      "fills": "base_url"
    }
  ],
  "resource": {
    "access": {},
    "defaults": {},
    "connector": "salesforce",
    "output": {
      "kind": "single",
      "collection": "records"
    },
    "credential_kind": "salesforce",
    "connection_fields": [
      "instance"
    ],
    "address": {
      "kind": "setup",
      "field": "instance",
      "prefix": "https://",
      "suffix": ".my.salesforce.com"
    }
  },
  "connection_setup": {
    "type": "object",
    "value": {
      "instance": {
        "fieldType": {
          "type": "string"
        },
        "optional": false
      }
    }
  },
  "execution": null
}

Native admission analysis is available for this exact declaration. Collection: records

Contract	Meaning
Initial	Enumeration of observed records
Changes	Current record read after a change indication
Deletions	Explicit deletion evidence
Resume	Opaque cursor
Gap	Explicit repair required after a gap
Retention	Unspecified

Complete native profile

{
  "movement": {
    "exchanges": {},
    "nativeInputLimitBytes": "0",
    "steps": [
      {
        "id": "acquire.1",
        "inputs": [],
        "action": {
          "operation": "acquire",
          "subject": "native input",
          "limitBytes": "0"
        }
      },
      {
        "id": "retain.1",
        "inputs": [
          "acquire.1"
        ],
        "action": {
          "operation": "retain",
          "subject": "acquisition evidence",
          "reason": "recovery",
          "release": "acquisition_custody"
        }
      },
      {
        "id": "interpret.1",
        "inputs": [
          "retain.1"
        ],
        "action": {
          "operation": "interpret",
          "subject": "acquired input",
          "produces": "records"
        }
      },
      {
        "id": "materialize.1",
        "inputs": [
          "interpret.1"
        ],
        "action": {
          "operation": "materialize",
          "subject": "source rows",
          "reason": "serving",
          "release": "replacement"
        }
      },
      {
        "id": "publish.1",
        "inputs": [
          "materialize.1"
        ],
        "action": {
          "operation": "publish",
          "subject": "source rows",
          "visibility": "with_acquisition"
        }
      }
    ]
  },
  "initial": "enumeration",
  "changes": "current_state_after_change",
  "deletions": "explicit_events",
  "resume": "opaque_cursor",
  "retentionMs": null,
  "gap": "explicit_repair",
  "limits": {
    "exchange_evidence_bytes": "524288",
    "publication_page_records": "128",
    "record_fields": "32"
  },
  "restrictions": [
    "Current rows in SystemModstamp order, bounded by the delete log's latestDateCovered; queryAll tombstones and getDeleted windows are the only deletions, and an expired delete log is a gap"
  ],
  "commands": {}
}

Commands, occurrences and artifacts

{
  "records": {
    "records": {
      "protocol": "record_observation",
      "coverage": "records",
      "consistency": "observations",
      "atomicity": "record",
      "history": "observations",
      "recordRefresh": false,
      "reconciliation": false,
      "notifications": false,
      "snapshotMaxRows": null,
      "profile": {
        "movement": {
          "exchanges": {},
          "nativeInputLimitBytes": "0",
          "steps": [
            {
              "id": "acquire.1",
              "inputs": [],
              "action": {
                "operation": "acquire",
                "subject": "native input",
                "limitBytes": "0"
              }
            },
            {
              "id": "retain.1",
              "inputs": [
                "acquire.1"
              ],
              "action": {
                "operation": "retain",
                "subject": "acquisition evidence",
                "reason": "recovery",
                "release": "acquisition_custody"
              }
            },
            {
              "id": "interpret.1",
              "inputs": [
                "retain.1"
              ],
              "action": {
                "operation": "interpret",
                "subject": "acquired input",
                "produces": "records"
              }
            },
            {
              "id": "materialize.1",
              "inputs": [
                "interpret.1"
              ],
              "action": {
                "operation": "materialize",
                "subject": "source rows",
                "reason": "serving",
                "release": "replacement"
              }
            },
            {
              "id": "publish.1",
              "inputs": [
                "materialize.1"
              ],
              "action": {
                "operation": "publish",
                "subject": "source rows",
                "visibility": "with_acquisition"
              }
            }
          ]
        },
        "initial": "enumeration",
        "changes": "current_state_after_change",
        "deletions": "explicit_events",
        "resume": "opaque_cursor",
        "retentionMs": null,
        "gap": "explicit_repair",
        "limits": {
          "exchange_evidence_bytes": "524288",
          "publication_page_records": "128",
          "record_fields": "32"
        },
        "restrictions": [
          "Current rows in SystemModstamp order, bounded by the delete log's latestDateCovered; queryAll tombstones and getDeleted windows are the only deletions, and an expired delete log is a gap"
        ],
        "commands": {}
      }
    }
  },
  "occurrences": null,
  "artifacts": {
    "raw_archive": false,
    "native_file_transfer_limit_bytes": null,
    "external_versions": false,
    "files": {}
  },
  "commands": {}
}

Recorded checks

Requirement	Scope	Evidence	Result
page-publication-recovery	{“kind”:“collection”,“name”:“records”}	No case-scoped check receipt is attached. The native reader’s statement, row, CSV and Pub/Sub decoding unit tests (connector_documents salesforce::records, connector_streams pubsub_api) are not scenario runs, and no Salesforce org has run these recipes.	Execution result unavailable

Hosted qualification: unestablished for this catalog configuration. Installed connections report their own identity, authority and current status.

discovery: Discovery and detail reads

The following example matches configuration standard.

import { salesforce } from "@bijection/connectors/salesforce";
import { v } from "bijection/values";
export const accounts = salesforce.objects.discovery({
  object: "Account",
  schema: { Id: v.string(), Name: v.string() },
  etags: true,
});

Inferred record types

{
  "Id": string;
  "Name": string;
}

Configuration: standard

Case: salesforce/objects/discovery/standard. Connection and resource configuration are declared by this exact case. Credential kind: salesforce. Keep credential material in the private credential inventory.

Setting	Type	Required	Owner
`instance`	string	Yes	Shared connection

Complete configuration contract

{
  "setup": [],
  "resource": {
    "access": {},
    "defaults": {},
    "connector": "salesforce",
    "output": {
      "kind": "single",
      "collection": "records"
    },
    "credential_kind": "salesforce",
    "connection_fields": [
      "instance"
    ],
    "address": {
      "kind": "setup",
      "field": "instance",
      "prefix": "https://",
      "suffix": ".my.salesforce.com"
    }
  },
  "connection_setup": {
    "type": "object",
    "value": {
      "instance": {
        "fieldType": {
          "type": "string"
        },
        "optional": false
      }
    }
  },
  "execution": null
}

Native admission analysis is available for this exact declaration. Collection: records

Contract	Meaning
Initial	Enumeration of observed records
Changes	Repeated observations of current records
Deletions	Explicit deletion evidence
Resume	Opaque cursor
Gap	Explicit repair required after a gap
Retention	Unspecified

Complete native profile

{
  "movement": {
    "exchanges": {
      "recordsDetail": {
        "200": {
          "placement": "retained_bytes",
          "interpretation": "json",
          "projectsBeforeRetention": false,
          "retainedBodyLimitBytes": "524288",
          "fileLimitBytes": null
        },
        "404": {
          "placement": "retained_bytes",
          "interpretation": "opaque",
          "projectsBeforeRetention": false,
          "retainedBodyLimitBytes": "524288",
          "fileLimitBytes": null
        }
      },
      "recordsListing": {
        "200": {
          "placement": "retained_bytes",
          "interpretation": "json",
          "projectsBeforeRetention": false,
          "retainedBodyLimitBytes": "524288",
          "fileLimitBytes": null
        }
      },
      "recordsMore": {
        "200": {
          "placement": "retained_bytes",
          "interpretation": "json",
          "projectsBeforeRetention": false,
          "retainedBodyLimitBytes": "524288",
          "fileLimitBytes": null
        }
      }
    },
    "nativeInputLimitBytes": null,
    "steps": [
      {
        "id": "acquire.1",
        "inputs": [],
        "action": {
          "operation": "acquire",
          "subject": "exchange recordsDetail",
          "limitBytes": null
        }
      },
      {
        "id": "acquire.2",
        "inputs": [],
        "action": {
          "operation": "acquire",
          "subject": "exchange recordsListing",
          "limitBytes": null
        }
      },
      {
        "id": "acquire.3",
        "inputs": [],
        "action": {
          "operation": "acquire",
          "subject": "exchange recordsMore",
          "limitBytes": null
        }
      },
      {
        "id": "retain.1",
        "inputs": [
          "acquire.1",
          "acquire.2",
          "acquire.3"
        ],
        "action": {
          "operation": "retain",
          "subject": "acquisition evidence",
          "reason": "recovery",
          "release": "acquisition_custody"
        }
      },
      {
        "id": "interpret.1",
        "inputs": [
          "retain.1"
        ],
        "action": {
          "operation": "interpret",
          "subject": "acquired input",
          "produces": "records"
        }
      },
      {
        "id": "materialize.1",
        "inputs": [
          "interpret.1"
        ],
        "action": {
          "operation": "materialize",
          "subject": "source rows",
          "reason": "serving",
          "release": "replacement"
        }
      },
      {
        "id": "publish.1",
        "inputs": [
          "materialize.1"
        ],
        "action": {
          "operation": "publish",
          "subject": "source rows",
          "visibility": "with_acquisition"
        }
      }
    ]
  },
  "initial": "enumeration",
  "changes": "observations",
  "deletions": "explicit_events",
  "resume": "opaque_cursor",
  "retentionMs": null,
  "gap": "explicit_repair",
  "limits": {
    "http_response_bytes": "524288"
  },
  "restrictions": [],
  "commands": {}
}

Commands, occurrences and artifacts

{
  "records": {
    "records": {
      "protocol": "record_observation",
      "coverage": "enumeration",
      "consistency": "observations",
      "atomicity": "record",
      "history": "observations",
      "recordRefresh": false,
      "reconciliation": false,
      "notifications": false,
      "snapshotMaxRows": null,
      "profile": {
        "movement": {
          "exchanges": {
            "recordsDetail": {
              "200": {
                "placement": "retained_bytes",
                "interpretation": "json",
                "projectsBeforeRetention": false,
                "retainedBodyLimitBytes": "524288",
                "fileLimitBytes": null
              },
              "404": {
                "placement": "retained_bytes",
                "interpretation": "opaque",
                "projectsBeforeRetention": false,
                "retainedBodyLimitBytes": "524288",
                "fileLimitBytes": null
              }
            },
            "recordsListing": {
              "200": {
                "placement": "retained_bytes",
                "interpretation": "json",
                "projectsBeforeRetention": false,
                "retainedBodyLimitBytes": "524288",
                "fileLimitBytes": null
              }
            },
            "recordsMore": {
              "200": {
                "placement": "retained_bytes",
                "interpretation": "json",
                "projectsBeforeRetention": false,
                "retainedBodyLimitBytes": "524288",
                "fileLimitBytes": null
              }
            }
          },
          "nativeInputLimitBytes": null,
          "steps": [
            {
              "id": "acquire.1",
              "inputs": [],
              "action": {
                "operation": "acquire",
                "subject": "exchange recordsDetail",
                "limitBytes": null
              }
            },
            {
              "id": "acquire.2",
              "inputs": [],
              "action": {
                "operation": "acquire",
                "subject": "exchange recordsListing",
                "limitBytes": null
              }
            },
            {
              "id": "acquire.3",
              "inputs": [],
              "action": {
                "operation": "acquire",
                "subject": "exchange recordsMore",
                "limitBytes": null
              }
            },
            {
              "id": "retain.1",
              "inputs": [
                "acquire.1",
                "acquire.2",
                "acquire.3"
              ],
              "action": {
                "operation": "retain",
                "subject": "acquisition evidence",
                "reason": "recovery",
                "release": "acquisition_custody"
              }
            },
            {
              "id": "interpret.1",
              "inputs": [
                "retain.1"
              ],
              "action": {
                "operation": "interpret",
                "subject": "acquired input",
                "produces": "records"
              }
            },
            {
              "id": "materialize.1",
              "inputs": [
                "interpret.1"
              ],
              "action": {
                "operation": "materialize",
                "subject": "source rows",
                "reason": "serving",
                "release": "replacement"
              }
            },
            {
              "id": "publish.1",
              "inputs": [
                "materialize.1"
              ],
              "action": {
                "operation": "publish",
                "subject": "source rows",
                "visibility": "with_acquisition"
              }
            }
          ]
        },
        "initial": "enumeration",
        "changes": "observations",
        "deletions": "explicit_events",
        "resume": "opaque_cursor",
        "retentionMs": null,
        "gap": "explicit_repair",
        "limits": {
          "http_response_bytes": "524288"
        },
        "restrictions": [],
        "commands": {}
      }
    }
  },
  "occurrences": null,
  "artifacts": {
    "raw_archive": false,
    "native_file_transfer_limit_bytes": null,
    "external_versions": false,
    "files": {}
  },
  "commands": {}
}

Recorded checks

Requirement	Scope	Evidence	Result
page-publication-recovery	{“kind”:“collection”,“name”:“records”}	No case-scoped check receipt is attached. The native reader’s statement, row, CSV and Pub/Sub decoding unit tests (connector_documents salesforce::records, connector_streams pubsub_api) are not scenario runs, and no Salesforce org has run these recipes.	Execution result unavailable
stated-cursor-empty-page-advances	{“kind”:“collection”,“name”:“records”}	No case-scoped check receipt is attached. The native reader’s statement, row, CSV and Pub/Sub decoding unit tests (connector_documents salesforce::records, connector_streams pubsub_api) are not scenario runs, and no Salesforce org has run these recipes.	Execution result unavailable
stated-cursor-repeat-refused	{“kind”:“collection”,“name”:“records”}	No case-scoped check receipt is attached. The native reader’s statement, row, CSV and Pub/Sub decoding unit tests (connector_documents salesforce::records, connector_streams pubsub_api) are not scenario runs, and no Salesforce org has run these recipes.	Execution result unavailable
identity-account	{“kind”:“connection”}	No case-scoped check receipt is attached. The native reader’s statement, row, CSV and Pub/Sub decoding unit tests (connector_documents salesforce::records, connector_streams pubsub_api) are not scenario runs, and no Salesforce org has run these recipes.	Execution result unavailable

Hosted qualification: unestablished for this catalog configuration. Installed connections report their own identity, authority and current status.

Platform events

platform: CometD

The following example matches configuration standard.

import { salesforce } from "@bijection/connectors/salesforce";
import { v } from "bijection/values";
const schema = { id: v.string() };
export const source = salesforce.events.platform({ schema, event: "Order__e" });

Inferred record types

{
  "eventId": string;
  "data": { id: string; };
}

Configuration: standard

Case: salesforce/events/platform/standard. Connection and resource configuration are declared by this exact case. Credential kind: salesforce. Keep credential material in the private credential inventory.

Setting	Type	Required	Owner
`instance`	string	Yes	Shared connection
`channel`	string	Yes	Resource binding

Provider setup requirements:

[
  {
    "key": "instance",
    "supplier": "account",
    "label": "Salesforce My Domain",
    "prefix": "https://",
    "suffix": ".my.salesforce.com",
    "fills": "base_url"
  }
]

Complete configuration contract

{
  "setup": [
    {
      "key": "instance",
      "supplier": "account",
      "label": "Salesforce My Domain",
      "prefix": "https://",
      "suffix": ".my.salesforce.com",
      "fills": "base_url"
    }
  ],
  "resource": {
    "access": {},
    "defaults": {
      "channel": "/event/Order__e"
    },
    "connector": "salesforce",
    "output": {
      "kind": "single",
      "collection": "records"
    },
    "credential_kind": "salesforce",
    "connection_fields": [
      "instance"
    ],
    "address": {
      "kind": "setup",
      "field": "instance",
      "prefix": "https://",
      "suffix": ".my.salesforce.com"
    },
    "projection": {
      "eventId": {
        "field": "event_id"
      },
      "data": {
        "field": "payload_json",
        "decode": "json"
      }
    }
  },
  "connection_setup": {
    "type": "object",
    "value": {
      "instance": {
        "fieldType": {
          "type": "string"
        },
        "optional": false
      },
      "channel": {
        "fieldType": {
          "type": "string"
        },
        "optional": false
      }
    }
  },
  "execution": null
}

Native admission analysis is available for this exact declaration. Collection: records

Contract	Meaning
Initial	No initial acquisition
Changes	Append-only history
Deletions	Deletion detection unsupported
Resume	Opaque cursor
Gap	Explicit repair required after a gap
Retention	Unspecified

Complete native profile

{
  "movement": {
    "exchanges": {},
    "nativeInputLimitBytes": "0",
    "steps": [
      {
        "id": "acquire.1",
        "inputs": [],
        "action": {
          "operation": "acquire",
          "subject": "native input",
          "limitBytes": "0"
        }
      },
      {
        "id": "retain.1",
        "inputs": [
          "acquire.1"
        ],
        "action": {
          "operation": "retain",
          "subject": "acquisition evidence",
          "reason": "recovery",
          "release": "acquisition_custody"
        }
      },
      {
        "id": "interpret.1",
        "inputs": [
          "retain.1"
        ],
        "action": {
          "operation": "interpret",
          "subject": "acquired input",
          "produces": "records"
        }
      },
      {
        "id": "materialize.1",
        "inputs": [
          "interpret.1"
        ],
        "action": {
          "operation": "materialize",
          "subject": "source rows",
          "reason": "serving",
          "release": "replacement"
        }
      },
      {
        "id": "publish.1",
        "inputs": [
          "materialize.1"
        ],
        "action": {
          "operation": "publish",
          "subject": "source rows",
          "visibility": "with_acquisition"
        }
      }
    ]
  },
  "initial": "none",
  "changes": "append_history",
  "deletions": "unsupported",
  "resume": "opaque_cursor",
  "retentionMs": null,
  "gap": "explicit_repair",
  "limits": {
    "exchange_evidence_bytes": "524288",
    "publication_page_records": "128",
    "record_fields": "32"
  },
  "restrictions": [
    "Event records and change notifications are not complete entity images or entity deletions"
  ],
  "commands": {}
}

Commands, occurrences and artifacts

{
  "records": {
    "records": {
      "protocol": "record_observation",
      "coverage": "records",
      "consistency": "observations",
      "atomicity": "record",
      "history": "observations",
      "recordRefresh": false,
      "reconciliation": false,
      "notifications": false,
      "snapshotMaxRows": null,
      "profile": {
        "movement": {
          "exchanges": {},
          "nativeInputLimitBytes": "0",
          "steps": [
            {
              "id": "acquire.1",
              "inputs": [],
              "action": {
                "operation": "acquire",
                "subject": "native input",
                "limitBytes": "0"
              }
            },
            {
              "id": "retain.1",
              "inputs": [
                "acquire.1"
              ],
              "action": {
                "operation": "retain",
                "subject": "acquisition evidence",
                "reason": "recovery",
                "release": "acquisition_custody"
              }
            },
            {
              "id": "interpret.1",
              "inputs": [
                "retain.1"
              ],
              "action": {
                "operation": "interpret",
                "subject": "acquired input",
                "produces": "records"
              }
            },
            {
              "id": "materialize.1",
              "inputs": [
                "interpret.1"
              ],
              "action": {
                "operation": "materialize",
                "subject": "source rows",
                "reason": "serving",
                "release": "replacement"
              }
            },
            {
              "id": "publish.1",
              "inputs": [
                "materialize.1"
              ],
              "action": {
                "operation": "publish",
                "subject": "source rows",
                "visibility": "with_acquisition"
              }
            }
          ]
        },
        "initial": "none",
        "changes": "append_history",
        "deletions": "unsupported",
        "resume": "opaque_cursor",
        "retentionMs": null,
        "gap": "explicit_repair",
        "limits": {
          "exchange_evidence_bytes": "524288",
          "publication_page_records": "128",
          "record_fields": "32"
        },
        "restrictions": [
          "Event records and change notifications are not complete entity images or entity deletions"
        ],
        "commands": {}
      }
    }
  },
  "occurrences": null,
  "artifacts": {
    "raw_archive": false,
    "native_file_transfer_limit_bytes": null,
    "external_versions": false,
    "files": {}
  },
  "commands": {}
}

Recorded checks

Requirement	Scope	Evidence	Result
page-publication-recovery	{“kind”:“collection”,“name”:“records”}	No case-scoped check receipt is attached. The native reader’s statement, row, CSV and Pub/Sub decoding unit tests (connector_documents salesforce::records, connector_streams pubsub_api) are not scenario runs, and no Salesforce org has run these recipes.	Execution result unavailable

Hosted qualification: unestablished for this catalog configuration. Installed connections report their own identity, authority and current status.

pubsub: Pub/Sub API

The following example matches configuration standard.

import { salesforce } from "@bijection/connectors/salesforce";
import { v } from "bijection/values";
const schema = { id: v.string() };
export const source = salesforce.events.pubsub({ schema, event: "Order__e" });

Inferred record types

{
  "eventId": string;
  "data": { id: string; };
}

Configuration: standard

Case: salesforce/events/pubsub/standard. Connection and resource configuration are declared by this exact case. Credential kind: salesforce. Keep credential material in the private credential inventory.

Setting	Type	Required	Owner
`instance`	string	Yes	Shared connection
`channel`	string	Yes	Resource binding

Provider setup requirements:

[
  {
    "key": "instance",
    "supplier": "account",
    "label": "Salesforce My Domain",
    "prefix": "https://",
    "suffix": ".my.salesforce.com",
    "fills": "base_url"
  }
]

Complete configuration contract

{
  "setup": [
    {
      "key": "instance",
      "supplier": "account",
      "label": "Salesforce My Domain",
      "prefix": "https://",
      "suffix": ".my.salesforce.com",
      "fills": "base_url"
    }
  ],
  "resource": {
    "access": {},
    "defaults": {
      "channel": "/event/Order__e"
    },
    "connector": "salesforce",
    "output": {
      "kind": "single",
      "collection": "records"
    },
    "credential_kind": "salesforce",
    "connection_fields": [
      "instance"
    ],
    "address": {
      "kind": "setup",
      "field": "instance",
      "prefix": "https://",
      "suffix": ".my.salesforce.com"
    },
    "projection": {
      "eventId": {
        "field": "event_id"
      },
      "data": {
        "field": "payload_json",
        "decode": "json"
      }
    }
  },
  "connection_setup": {
    "type": "object",
    "value": {
      "instance": {
        "fieldType": {
          "type": "string"
        },
        "optional": false
      },
      "channel": {
        "fieldType": {
          "type": "string"
        },
        "optional": false
      }
    }
  },
  "execution": null
}

Native admission analysis is available for this exact declaration. Collection: records

Contract	Meaning
Initial	No initial acquisition
Changes	Append-only history
Deletions	Deletion detection unsupported
Resume	Opaque cursor
Gap	Explicit repair required after a gap
Retention	Unspecified

Complete native profile

{
  "movement": {
    "exchanges": {},
    "nativeInputLimitBytes": "0",
    "steps": [
      {
        "id": "acquire.1",
        "inputs": [],
        "action": {
          "operation": "acquire",
          "subject": "native input",
          "limitBytes": "0"
        }
      },
      {
        "id": "retain.1",
        "inputs": [
          "acquire.1"
        ],
        "action": {
          "operation": "retain",
          "subject": "acquisition evidence",
          "reason": "recovery",
          "release": "acquisition_custody"
        }
      },
      {
        "id": "interpret.1",
        "inputs": [
          "retain.1"
        ],
        "action": {
          "operation": "interpret",
          "subject": "acquired input",
          "produces": "records"
        }
      },
      {
        "id": "materialize.1",
        "inputs": [
          "interpret.1"
        ],
        "action": {
          "operation": "materialize",
          "subject": "source rows",
          "reason": "serving",
          "release": "replacement"
        }
      },
      {
        "id": "publish.1",
        "inputs": [
          "materialize.1"
        ],
        "action": {
          "operation": "publish",
          "subject": "source rows",
          "visibility": "with_acquisition"
        }
      }
    ]
  },
  "initial": "none",
  "changes": "append_history",
  "deletions": "unsupported",
  "resume": "opaque_cursor",
  "retentionMs": null,
  "gap": "explicit_repair",
  "limits": {
    "exchange_evidence_bytes": "524288",
    "publication_page_records": "128",
    "record_fields": "32"
  },
  "restrictions": [
    "Event records and change notifications are not complete entity images or entity deletions"
  ],
  "commands": {}
}

Commands, occurrences and artifacts

{
  "records": {
    "records": {
      "protocol": "record_observation",
      "coverage": "records",
      "consistency": "observations",
      "atomicity": "record",
      "history": "observations",
      "recordRefresh": false,
      "reconciliation": false,
      "notifications": false,
      "snapshotMaxRows": null,
      "profile": {
        "movement": {
          "exchanges": {},
          "nativeInputLimitBytes": "0",
          "steps": [
            {
              "id": "acquire.1",
              "inputs": [],
              "action": {
                "operation": "acquire",
                "subject": "native input",
                "limitBytes": "0"
              }
            },
            {
              "id": "retain.1",
              "inputs": [
                "acquire.1"
              ],
              "action": {
                "operation": "retain",
                "subject": "acquisition evidence",
                "reason": "recovery",
                "release": "acquisition_custody"
              }
            },
            {
              "id": "interpret.1",
              "inputs": [
                "retain.1"
              ],
              "action": {
                "operation": "interpret",
                "subject": "acquired input",
                "produces": "records"
              }
            },
            {
              "id": "materialize.1",
              "inputs": [
                "interpret.1"
              ],
              "action": {
                "operation": "materialize",
                "subject": "source rows",
                "reason": "serving",
                "release": "replacement"
              }
            },
            {
              "id": "publish.1",
              "inputs": [
                "materialize.1"
              ],
              "action": {
                "operation": "publish",
                "subject": "source rows",
                "visibility": "with_acquisition"
              }
            }
          ]
        },
        "initial": "none",
        "changes": "append_history",
        "deletions": "unsupported",
        "resume": "opaque_cursor",
        "retentionMs": null,
        "gap": "explicit_repair",
        "limits": {
          "exchange_evidence_bytes": "524288",
          "publication_page_records": "128",
          "record_fields": "32"
        },
        "restrictions": [
          "Event records and change notifications are not complete entity images or entity deletions"
        ],
        "commands": {}
      }
    }
  },
  "occurrences": null,
  "artifacts": {
    "raw_archive": false,
    "native_file_transfer_limit_bytes": null,
    "external_versions": false,
    "files": {}
  },
  "commands": {}
}

Recorded checks

Requirement	Scope	Evidence	Result
page-publication-recovery	{“kind”:“collection”,“name”:“records”}	No case-scoped check receipt is attached. The native reader’s statement, row, CSV and Pub/Sub decoding unit tests (connector_documents salesforce::records, connector_streams pubsub_api) are not scenario runs, and no Salesforce org has run these recipes.	Execution result unavailable

Hosted qualification: unestablished for this catalog configuration. Installed connections report their own identity, authority and current status.

Change data capture

cdc: CometD

The following example matches configuration standard.

import { salesforce } from "@bijection/connectors/salesforce";
import { v } from "bijection/values";
const schema = { id: v.string() };
export const source = salesforce.changes.cdc({ schema, object: "Account" });

Inferred record types

{
  "eventId": string;
  "data": { id: string; };
}

Configuration: standard

Case: salesforce/changes/cdc/standard. Connection and resource configuration are declared by this exact case. Credential kind: salesforce. Keep credential material in the private credential inventory.

Setting	Type	Required	Owner
`instance`	string	Yes	Shared connection
`channel`	string	Yes	Resource binding

Provider setup requirements:

[
  {
    "key": "instance",
    "supplier": "account",
    "label": "Salesforce My Domain",
    "prefix": "https://",
    "suffix": ".my.salesforce.com",
    "fills": "base_url"
  }
]

Complete configuration contract

{
  "setup": [
    {
      "key": "instance",
      "supplier": "account",
      "label": "Salesforce My Domain",
      "prefix": "https://",
      "suffix": ".my.salesforce.com",
      "fills": "base_url"
    }
  ],
  "resource": {
    "access": {},
    "defaults": {
      "channel": "/data/AccountChangeEvent"
    },
    "connector": "salesforce",
    "output": {
      "kind": "single",
      "collection": "records"
    },
    "credential_kind": "salesforce",
    "connection_fields": [
      "instance"
    ],
    "address": {
      "kind": "setup",
      "field": "instance",
      "prefix": "https://",
      "suffix": ".my.salesforce.com"
    },
    "projection": {
      "eventId": {
        "field": "event_id"
      },
      "data": {
        "field": "payload_json",
        "decode": "json"
      }
    }
  },
  "connection_setup": {
    "type": "object",
    "value": {
      "instance": {
        "fieldType": {
          "type": "string"
        },
        "optional": false
      },
      "channel": {
        "fieldType": {
          "type": "string"
        },
        "optional": false
      }
    }
  },
  "execution": null
}

Native admission analysis is available for this exact declaration. Collection: records

Contract	Meaning
Initial	No initial acquisition
Changes	Append-only history
Deletions	Deletion detection unsupported
Resume	Opaque cursor
Gap	Explicit repair required after a gap
Retention	Unspecified

Complete native profile

{
  "movement": {
    "exchanges": {},
    "nativeInputLimitBytes": "0",
    "steps": [
      {
        "id": "acquire.1",
        "inputs": [],
        "action": {
          "operation": "acquire",
          "subject": "native input",
          "limitBytes": "0"
        }
      },
      {
        "id": "retain.1",
        "inputs": [
          "acquire.1"
        ],
        "action": {
          "operation": "retain",
          "subject": "acquisition evidence",
          "reason": "recovery",
          "release": "acquisition_custody"
        }
      },
      {
        "id": "interpret.1",
        "inputs": [
          "retain.1"
        ],
        "action": {
          "operation": "interpret",
          "subject": "acquired input",
          "produces": "records"
        }
      },
      {
        "id": "materialize.1",
        "inputs": [
          "interpret.1"
        ],
        "action": {
          "operation": "materialize",
          "subject": "source rows",
          "reason": "serving",
          "release": "replacement"
        }
      },
      {
        "id": "publish.1",
        "inputs": [
          "materialize.1"
        ],
        "action": {
          "operation": "publish",
          "subject": "source rows",
          "visibility": "with_acquisition"
        }
      }
    ]
  },
  "initial": "none",
  "changes": "append_history",
  "deletions": "unsupported",
  "resume": "opaque_cursor",
  "retentionMs": null,
  "gap": "explicit_repair",
  "limits": {
    "exchange_evidence_bytes": "524288",
    "publication_page_records": "128",
    "record_fields": "32"
  },
  "restrictions": [
    "Event records and change notifications are not complete entity images or entity deletions"
  ],
  "commands": {}
}

Commands, occurrences and artifacts

{
  "records": {
    "records": {
      "protocol": "record_observation",
      "coverage": "records",
      "consistency": "observations",
      "atomicity": "record",
      "history": "observations",
      "recordRefresh": false,
      "reconciliation": false,
      "notifications": false,
      "snapshotMaxRows": null,
      "profile": {
        "movement": {
          "exchanges": {},
          "nativeInputLimitBytes": "0",
          "steps": [
            {
              "id": "acquire.1",
              "inputs": [],
              "action": {
                "operation": "acquire",
                "subject": "native input",
                "limitBytes": "0"
              }
            },
            {
              "id": "retain.1",
              "inputs": [
                "acquire.1"
              ],
              "action": {
                "operation": "retain",
                "subject": "acquisition evidence",
                "reason": "recovery",
                "release": "acquisition_custody"
              }
            },
            {
              "id": "interpret.1",
              "inputs": [
                "retain.1"
              ],
              "action": {
                "operation": "interpret",
                "subject": "acquired input",
                "produces": "records"
              }
            },
            {
              "id": "materialize.1",
              "inputs": [
                "interpret.1"
              ],
              "action": {
                "operation": "materialize",
                "subject": "source rows",
                "reason": "serving",
                "release": "replacement"
              }
            },
            {
              "id": "publish.1",
              "inputs": [
                "materialize.1"
              ],
              "action": {
                "operation": "publish",
                "subject": "source rows",
                "visibility": "with_acquisition"
              }
            }
          ]
        },
        "initial": "none",
        "changes": "append_history",
        "deletions": "unsupported",
        "resume": "opaque_cursor",
        "retentionMs": null,
        "gap": "explicit_repair",
        "limits": {
          "exchange_evidence_bytes": "524288",
          "publication_page_records": "128",
          "record_fields": "32"
        },
        "restrictions": [
          "Event records and change notifications are not complete entity images or entity deletions"
        ],
        "commands": {}
      }
    }
  },
  "occurrences": null,
  "artifacts": {
    "raw_archive": false,
    "native_file_transfer_limit_bytes": null,
    "external_versions": false,
    "files": {}
  },
  "commands": {}
}

Recorded checks

Requirement	Scope	Evidence	Result
page-publication-recovery	{“kind”:“collection”,“name”:“records”}	No case-scoped check receipt is attached. The native reader’s statement, row, CSV and Pub/Sub decoding unit tests (connector_documents salesforce::records, connector_streams pubsub_api) are not scenario runs, and no Salesforce org has run these recipes.	Execution result unavailable

Hosted qualification: unestablished for this catalog configuration. Installed connections report their own identity, authority and current status.

pubsub: Pub/Sub API

The following example matches configuration standard.

import { salesforce } from "@bijection/connectors/salesforce";
import { v } from "bijection/values";
const schema = { id: v.string() };
export const source = salesforce.changes.pubsub({ schema, object: "Account" });

Inferred record types

{
  "eventId": string;
  "data": { id: string; };
}

Configuration: standard

Case: salesforce/changes/pubsub/standard. Connection and resource configuration are declared by this exact case. Credential kind: salesforce. Keep credential material in the private credential inventory.

Setting	Type	Required	Owner
`instance`	string	Yes	Shared connection
`channel`	string	Yes	Resource binding

Provider setup requirements:

[
  {
    "key": "instance",
    "supplier": "account",
    "label": "Salesforce My Domain",
    "prefix": "https://",
    "suffix": ".my.salesforce.com",
    "fills": "base_url"
  }
]

Complete configuration contract

{
  "setup": [
    {
      "key": "instance",
      "supplier": "account",
      "label": "Salesforce My Domain",
      "prefix": "https://",
      "suffix": ".my.salesforce.com",
      "fills": "base_url"
    }
  ],
  "resource": {
    "access": {},
    "defaults": {
      "channel": "/data/AccountChangeEvent"
    },
    "connector": "salesforce",
    "output": {
      "kind": "single",
      "collection": "records"
    },
    "credential_kind": "salesforce",
    "connection_fields": [
      "instance"
    ],
    "address": {
      "kind": "setup",
      "field": "instance",
      "prefix": "https://",
      "suffix": ".my.salesforce.com"
    },
    "projection": {
      "eventId": {
        "field": "event_id"
      },
      "data": {
        "field": "payload_json",
        "decode": "json"
      }
    }
  },
  "connection_setup": {
    "type": "object",
    "value": {
      "instance": {
        "fieldType": {
          "type": "string"
        },
        "optional": false
      },
      "channel": {
        "fieldType": {
          "type": "string"
        },
        "optional": false
      }
    }
  },
  "execution": null
}

Native admission analysis is available for this exact declaration. Collection: records

Contract	Meaning
Initial	No initial acquisition
Changes	Append-only history
Deletions	Deletion detection unsupported
Resume	Opaque cursor
Gap	Explicit repair required after a gap
Retention	Unspecified

Complete native profile

{
  "movement": {
    "exchanges": {},
    "nativeInputLimitBytes": "0",
    "steps": [
      {
        "id": "acquire.1",
        "inputs": [],
        "action": {
          "operation": "acquire",
          "subject": "native input",
          "limitBytes": "0"
        }
      },
      {
        "id": "retain.1",
        "inputs": [
          "acquire.1"
        ],
        "action": {
          "operation": "retain",
          "subject": "acquisition evidence",
          "reason": "recovery",
          "release": "acquisition_custody"
        }
      },
      {
        "id": "interpret.1",
        "inputs": [
          "retain.1"
        ],
        "action": {
          "operation": "interpret",
          "subject": "acquired input",
          "produces": "records"
        }
      },
      {
        "id": "materialize.1",
        "inputs": [
          "interpret.1"
        ],
        "action": {
          "operation": "materialize",
          "subject": "source rows",
          "reason": "serving",
          "release": "replacement"
        }
      },
      {
        "id": "publish.1",
        "inputs": [
          "materialize.1"
        ],
        "action": {
          "operation": "publish",
          "subject": "source rows",
          "visibility": "with_acquisition"
        }
      }
    ]
  },
  "initial": "none",
  "changes": "append_history",
  "deletions": "unsupported",
  "resume": "opaque_cursor",
  "retentionMs": null,
  "gap": "explicit_repair",
  "limits": {
    "exchange_evidence_bytes": "524288",
    "publication_page_records": "128",
    "record_fields": "32"
  },
  "restrictions": [
    "Event records and change notifications are not complete entity images or entity deletions"
  ],
  "commands": {}
}

Commands, occurrences and artifacts

{
  "records": {
    "records": {
      "protocol": "record_observation",
      "coverage": "records",
      "consistency": "observations",
      "atomicity": "record",
      "history": "observations",
      "recordRefresh": false,
      "reconciliation": false,
      "notifications": false,
      "snapshotMaxRows": null,
      "profile": {
        "movement": {
          "exchanges": {},
          "nativeInputLimitBytes": "0",
          "steps": [
            {
              "id": "acquire.1",
              "inputs": [],
              "action": {
                "operation": "acquire",
                "subject": "native input",
                "limitBytes": "0"
              }
            },
            {
              "id": "retain.1",
              "inputs": [
                "acquire.1"
              ],
              "action": {
                "operation": "retain",
                "subject": "acquisition evidence",
                "reason": "recovery",
                "release": "acquisition_custody"
              }
            },
            {
              "id": "interpret.1",
              "inputs": [
                "retain.1"
              ],
              "action": {
                "operation": "interpret",
                "subject": "acquired input",
                "produces": "records"
              }
            },
            {
              "id": "materialize.1",
              "inputs": [
                "interpret.1"
              ],
              "action": {
                "operation": "materialize",
                "subject": "source rows",
                "reason": "serving",
                "release": "replacement"
              }
            },
            {
              "id": "publish.1",
              "inputs": [
                "materialize.1"
              ],
              "action": {
                "operation": "publish",
                "subject": "source rows",
                "visibility": "with_acquisition"
              }
            }
          ]
        },
        "initial": "none",
        "changes": "append_history",
        "deletions": "unsupported",
        "resume": "opaque_cursor",
        "retentionMs": null,
        "gap": "explicit_repair",
        "limits": {
          "exchange_evidence_bytes": "524288",
          "publication_page_records": "128",
          "record_fields": "32"
        },
        "restrictions": [
          "Event records and change notifications are not complete entity images or entity deletions"
        ],
        "commands": {}
      }
    }
  },
  "occurrences": null,
  "artifacts": {
    "raw_archive": false,
    "native_file_transfer_limit_bytes": null,
    "external_versions": false,
    "files": {}
  },
  "commands": {}
}

Recorded checks

Requirement	Scope	Evidence	Result
page-publication-recovery	{“kind”:“collection”,“name”:“records”}	No case-scoped check receipt is attached. The native reader’s statement, row, CSV and Pub/Sub decoding unit tests (connector_documents salesforce::records, connector_streams pubsub_api) are not scenario runs, and no Salesforce org has run these recipes.	Execution result unavailable

Hosted qualification: unestablished for this catalog configuration. Installed connections report their own identity, authority and current status.

Provider guidance

Compiled declaration examples and configuration details are published in the connector reference. Every resource binds the same salesforce connection: the binding names the org’s My Domain (instance, rendered https://<instance>.my.salesforce.com) and salesforce.credential(name) holds only its OAuth access_token. Select fields with schema (and fields when a stored name differs from the sObject field); bijection source metadata capture salesforce generates typed selections from the org’s Describe, and the reader rechecks the selection against Describe before its first read.

Object records

objects.incremental uses the native salesforce transport. Each round opens with a getDeleted window: its ids are published as deletions, including records already purged from the recycle bin, and its latestDateCovered bounds a queryAll walk in (SystemModstamp, Id) order, 128 rows per page. IsDeleted rows are deletions; every other row is the current record, versioned by SystemModstamp. Ties on one stamp continue by Id, so mass updates cannot stall the walk. initial: "bulk" reads the first pass as one Bulk API 2.0 queryAll job (CSV typed by Describe; a CSV null and an empty text are both null), then walks strictly after the job’s bound. A delete log that no longer covers the next window, or a failed or expired bulk job, is a gap that requires a new source basis. Records are observations, not a snapshot, and absence never withdraws one. objects.discovery is the bounded discovery and detail recipe over HTTP: queryAll of Id, IsDeleted, then one detail read per key. With etags the detail ETag is the record version an If-Match write can condition on. It does not observe records purged from the recycle bin.

Events and changes

events.platform and changes.cdc read CometD with the replay extension; events.pubsub and changes.pubsub read the gRPC Pub/Sub API (api.pubsub.salesforce.com:7443, or endpoint), fetching each event’s Avro schema and requesting one page of 32 events per subscription. Both share one replay position, one event identity window and one gap rule: CometD names an event by EventUuid, Pub/Sub by the producer event’s id; a change event is entity:transactionKey:sequenceNumber; DELETE and UNDELETE are accepted change kinds and any GAP_* kind is a gap. Pub/Sub replay ids are retained only when they are eight bytes. Nothing here has run against a Salesforce org; inspect the installed source’s profile for its exact guarantees.

Provider references

Provider references and prerequisites are maintained in the connector guidance above. No separate provider-documentation review date is recorded.

Source and evidence

Canonical connector source, native analysis and check receipts. Connector artifact: 905888ea276a2a28e36981a79e8142b2547ea451c3e63162cb6915ad4a7d1305. The resource declaration examples above are compiled and compared with exact catalog declarations. Recorded checks apply only to their source, declaration and runtime identities. Configure a connection and inspect its status to establish deployment-specific readiness.

Get Started

Use-case atlas

Platform

Data and Operations

Guides

Client Libraries

Tools

API Reference

Availability

Resources and modes

Object records

incremental: Ordered walk with deletion windows

Configuration: standard

Configuration: bulk

discovery: Discovery and detail reads

Configuration: standard

Platform events

platform: CometD

Configuration: standard

pubsub: Pub/Sub API

Configuration: standard

Change data capture

cdc: CometD

Configuration: standard

pubsub: Pub/Sub API

Configuration: standard

Provider guidance

Object records

Events and changes

Provider references

Source and evidence

​Availability

​Resources and modes

​Object records

​incremental: Ordered walk with deletion windows

​Configuration: standard

​Configuration: bulk

​discovery: Discovery and detail reads

​Configuration: standard

​Platform events

​platform: CometD

​Configuration: standard

​pubsub: Pub/Sub API

​Configuration: standard

​Change data capture

​cdc: CometD

​Configuration: standard

​pubsub: Pub/Sub API

​Configuration: standard

​Provider guidance

​Object records

​Events and changes

​Provider references

​Source and evidence

Availability

Resources and modes

Object records

incremental: Ordered walk with deletion windows

Configuration: standard

Configuration: bulk

discovery: Discovery and detail reads

Configuration: standard

Platform events

platform: CometD

Configuration: standard

pubsub: Pub/Sub API

Configuration: standard

Change data capture

cdc: CometD

Configuration: standard

pubsub: Pub/Sub API

Configuration: standard

Provider guidance

Object records

Events and changes

Provider references

Source and evidence