package
0.5.1
Repository: https://github.com/estuary/flow.git
Documentation: pkg.go.dev

# Functions

No description provided by the author
No description provided by the author

# Variables

No description provided by the author
No description provided by the author
No description provided by the author

# Structs

No description provided by the author
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.
No description provided by the author
No description provided by the author
Flushed responds to Request.Flush, and indicates that all documents have been published.
Opened responds to Request.Open.
No description provided by the author
Spec responds to Request.Spec.
StartedCommit responds to a Request.StartCommit, and includes an optional connector state update.
Validated responds to Request.Validate.
No description provided by the author
UnimplementedConnectorServer can be embedded to have forward compatible implementations.

# Interfaces

No description provided by the author
No description provided by the author
ConnectorClient is the client API for Connector service.
ConnectorServer is the server API for Connector service.