grpcbinlogstreamer

Documentation

Overview

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

Index

• type UpdateStream
  • func New(updateStream binlog.UpdateStream) *UpdateStream
  • func (server *UpdateStream) StreamKeyRange(req *binlogdatapb.StreamKeyRangeRequest, ...) (err error)
  • func (server *UpdateStream) StreamTables(req *binlogdatapb.StreamTablesRequest, ...) (err error)
  • func (server *UpdateStream) StreamUpdate(req *binlogdatapb.StreamUpdateRequest, ...) (err error)

Types

type UpdateStream

type UpdateStream struct {
	// 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

func (*UpdateStream) StreamUpdate

func (server *UpdateStream) StreamUpdate(req *binlogdatapb.StreamUpdateRequest, stream binlogservicepb.UpdateStream_StreamUpdateServer) (err error)

StreamUpdate is part of the binlogservicepb.UpdateStreamServer interface