Documentation ¶
Overview ¶
Package grpcbinlogstreamer contains the gRPC implementation of the binlog streamer server component.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type UpdateStream ¶
type UpdateStream struct { binlogservicepb.UnimplementedUpdateStreamServer // contains filtered or unexported fields }
UpdateStream is the gRPC UpdateStream server
func New ¶
func New(updateStream binlog.UpdateStream) *UpdateStream
New returns a new go rpc server implementation stub for UpdateStream
func (*UpdateStream) StreamKeyRange ¶
func (server *UpdateStream) StreamKeyRange(req *binlogdatapb.StreamKeyRangeRequest, stream binlogservicepb.UpdateStream_StreamKeyRangeServer) (err error)
StreamKeyRange is part of the binlogservicepb.UpdateStreamServer interface
func (*UpdateStream) StreamTables ¶
func (server *UpdateStream) StreamTables(req *binlogdatapb.StreamTablesRequest, stream binlogservicepb.UpdateStream_StreamTablesServer) (err error)
StreamTables is part of the binlogservicepb.UpdateStreamServer interface
Click to show internal directories.
Click to hide internal directories.