Package binlogplayer contains the code that plays a vreplication stream on a client database.

Package eventtoken includes utility methods for event token handling.

Package grpcbinlogstreamer contains the gRPC implementation of the binlog streamer server component.

KeyRangeFilterFunc returns a function that calls callback only if statements in the transaction match the specified keyrange.

NewEventStreamer returns a new EventStreamer on top of a Streamer.

NewSlaveConnection creates a new slave connection to the mysqld instance.

NewStreamer creates a binlog Streamer.

NewUpdateStream returns a new UpdateStreamImpl object.

NewUpdateStreamControlMock creates a new UpdateStreamControlMock.

TablesFilterFunc returns a function that calls callback only if statements in the transaction match the specified tables.

ErrBinlogUnavailable is returned by this library when we cannot find a suitable binlog to satisfy the request.

ErrClientEOF is returned by Streamer if the stream ended because the consumer of the stream indicated it doesn't want any more events.

ErrServerEOF is returned by Streamer if the stream ended because the connection to the mysqld server was lost, or the stream was terminated by mysqld.

RegisterUpdateStreamServices is the list of all registration callbacks to invoke.

EventStreamer is an adapter on top of a binlog Streamer that convert the events into StreamEvent objects.

FullBinlogStatement has all the information we can gather for an event.

SlaveConnection represents a connection to mysqld that pretends to be a slave connecting for replication.

Streamer streams binlog events from MySQL by connecting as a slave.

StreamList is a map of context.CancelFunc to mass-interrupt ongoing calls.

UpdateStreamControlMock is an implementation of UpdateStreamControl to be used in tests.

UpdateStreamImpl is the real implementation of UpdateStream and UpdateStreamControl.

UpdateStream is the interface for the binlog server.

UpdateStreamControl is the interface an UpdateStream service implements to bring it up or down.

RegisterUpdateStreamServiceFunc is the type to use for delayed registration of RPC servers until we have all the objects.