Flush tells the connector it should immediately complete any deferred work and respond with Published documents for all previously Read documents, and then respond with Flushed.

Open a derivation stream.

Read a document for one of the Opened transforms.

Shuffle under which this document was mapped.

Reset any internal state, as if the derivation were just initialized.

Spec requests the specification definition of this connector.

StartCommit indicates that the Flow runtime is beginning to commit.

Validate a derivation configuration and proposed transforms.

Flushed responds to Request.Flush, and indicates that all documents have been published.

Opened responds to Request.Open.

Spec responds to Request.Spec.

StartedCommit responds to a Request.StartCommit, and includes an optional connector state update.

Validated responds to Request.Validate.

UnimplementedConnectorServer can be embedded to have forward compatible implementations.

ConnectorClient is the client API for Connector service.

ConnectorServer is the server API for Connector service.