Package binlogplayer contains the code that plays a filtered replication 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 sendReply only if statements in the transaction match the specified keyrange.

NewEventStreamer returns a new EventStreamer on top of a Streamer.

NewStreamer creates a binlog Streamer.

NewUpdateStream returns a new UpdateStreamImpl object.

NewUpdateStreamControlMock creates a new UpdateStreamControlMock.

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

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.

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.