grpcbinlogstreamer

Documentation

Overview

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

Index

• type UpdateStream
  • func New(updateStream proto.UpdateStream) *UpdateStream
  • func (server *UpdateStream) StreamKeyRange(req *pb.StreamKeyRangeRequest, stream pbs.UpdateStream_StreamKeyRangeServer) (err error)
  • func (server *UpdateStream) StreamTables(req *pb.StreamTablesRequest, stream pbs.UpdateStream_StreamTablesServer) (err error)
  • func (server *UpdateStream) StreamUpdate(req *pb.StreamUpdateRequest, stream pbs.UpdateStream_StreamUpdateServer) (err error)

Types

type UpdateStream

type UpdateStream struct {
	// contains filtered or unexported fields
}

UpdateStream is the gRPC UpdateStream server

func New

func New(updateStream proto.UpdateStream) *UpdateStream

New returns a new go rpc server implementation stub for UpdateStream

func (*UpdateStream) StreamKeyRange

func (server *UpdateStream) StreamKeyRange(req *pb.StreamKeyRangeRequest, stream pbs.UpdateStream_StreamKeyRangeServer) (err error)

StreamKeyRange is part of the pbs.UpdateStreamServer interface

func (*UpdateStream) StreamTables

func (server *UpdateStream) StreamTables(req *pb.StreamTablesRequest, stream pbs.UpdateStream_StreamTablesServer) (err error)

StreamTables is part of the pbs.UpdateStreamServer interface

func (*UpdateStream) StreamUpdate

func (server *UpdateStream) StreamUpdate(req *pb.StreamUpdateRequest, stream pbs.UpdateStream_StreamUpdateServer) (err error)

StreamUpdate is part of the pbs.UpdateStreamServer interface