RunTransactions processes materialization protocol transactions over the established stream against a Connector.

This projection must not be present in the materialization.

This projection may be included, but should be omitted by default.

This specific projection must be present.

A projection with this location is recommended, and should be included by default.

At least one projection with this location pointer must be present.

This specific projection is required but is also unacceptable (e.x., because it uses an incompatible type with a previous applied version).

ExplicitZeroCheckpoint is a zero-valued message encoding, implemented as a trivial encoding of the max-value 2^29-1 protobuf tag with boolean true.

Extra messages used by connectors TODO(johnny): Do we still need this?.

LoadIterator is an iterator over Load requests.

Acknowledge to the connector that the previous transaction has committed to the Flow runtime's recovery log.

Apply a materialization configuration and bindings to its endpoint.

Flush loads.

Load a document identified by its key.

Open a materialization stream.

Spec requests the specification definition of this connector.

Mark the end of the Store phase, and if the remote store is authoritative, instruct it to start committing its transaction.

Store documents updated by the current transaction.

Validate a materialization configuration and proposed bindings.

Bindings of endpoint resources and collections from which they would be materialized.

Notify the runtime that the previous transaction has committed.

Applied responds to Request.Apply.

Flushed responds to a Request.Flush.

Loaded responds to Request.Load.

Opened responds to Request.Open.

Spec responds to Request.Spec.

StartedCommit responds to a Request.StartCommit.

Validated responds to Request.Validate.

Validation responses for each binding of the request, and matching the request ordering.

Constraint constrains the use of a flow.Projection within a materialization.

StoreIterator is an iterator over Store requests.

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.

Transactor is a store-agnostic interface for a materialization connector that implements Flow materialization protocol transactions.

Type encodes a constraint type for this flow.Projection.

StartCommitFunc begins to commit a stored transaction.