AdaptServerToClient wraps an in-process DriverServer to provide a DriverClient.

NewPushServer builds a new *PushServer using the provided CaptureSpec.

OpenPull opens a Pull RPC using the provided DriverClient and CaptureSpec.

PullResponseChannel spawns a goroutine which receives from the stream and sends responses into the returned channel, which is closed after the first encountered read error.

ReadPushCheckpoint reads Documents from a Push RPC until a checkpoint is countered.

Rx receives from a PullResponseError channel.

StagePullDocuments potentially sends a previously staged Documents into the stream, and then stages its arguments into response.Captured.

StagePushDocuments potentially sends a previously staged Documents into the stream, and then stages its arguments into response.Captured.

WritePullCheckpoint flushes a pending Documents response, and sends a Checkpoint response with the provided driver checkpoint.

WritePushCheckpoint flushes a pending Documents response, and sends a Checkpoint response with the provided driver checkpoint.

Acknowledge is a notification that a Checkpoint has committed to the Flow runtime's recovery log.

ApplyRequest is the request type of the ApplyUpsert and ApplyDelete RPCs.

ApplyResponse is the response type of the ApplyUpsert and ApplyDelete RPCs.

DiscoverRequest is the request type of the Discover RPC.

DiscoverResponse is the response type of the Discover RPC.

Potential bindings which the capture could provide.

Documents is a set of documents drawn from a binding of the capture.

PullClient is a client of a driver's Pull RPC.

PullRequest is the request type of a Driver.Pull RPC.

Open opens a Pull of the driver, and is sent exactly once as the first message of the stream.

PullResponse is the response type of a Driver.Pull RPC.

Opened responds to PullRequest.Open of the runtime, and is sent exactly once as the first message of the stream.

PullResponseError is a channel-oriented wrapper of PullResponse.

PushRequest is the request message of the Runtime.Push RPC.

Open opens a Push of the runtime, and is sent exactly once as the first message of the stream.

PushResponse is the response message of the Runtime.Push RPC.

Opened responds to PushRequest.Open of the driver, and is sent exactly once as the first message of the stream.

PullServer is a server which aides implementations of the Runtime.Push RPC.

SpecRequest is the request type of the Spec RPC.

SpecResponse is the response type of the Spec RPC.

UnimplementedDriverServer can be embedded to have forward compatible implementations.

UnimplementedRuntimeServer can be embedded to have forward compatible implementations.

ValidateRequest is the request type of the Validate RPC.

Bindings of endpoint resources and collections to which they would be captured.

ValidateResponse is the response type of the Validate RPC.

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

DriverClient is the client API for Driver service.

DriverServer is the server API for Driver service.

RuntimeClient is the client API for Runtime service.

RuntimeServer is the server API for Runtime service.