gorpcbinlogstreamer

Documentation

Index

• type UpdateStream
  • func New(updateStream proto.UpdateStream) *UpdateStream
  • func (server *UpdateStream) ServeUpdateStream(req *proto.UpdateStreamRequest, sendReply func(reply interface{}) error) (err error)
  • func (server *UpdateStream) StreamKeyRange(req *proto.KeyRangeRequest, sendReply func(reply interface{}) error) (err error)
  • func (server *UpdateStream) StreamTables(req *proto.TablesRequest, sendReply func(reply interface{}) error) (err error)

Types

type UpdateStream

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

UpdateStream is the go rpc UpdateStream server

func New

func New(updateStream proto.UpdateStream) *UpdateStream

New returns a new go rpc server implementation stub for UpdateStream

func (*UpdateStream) ServeUpdateStream

func (server *UpdateStream) ServeUpdateStream(req *proto.UpdateStreamRequest, sendReply func(reply interface{}) error) (err error)

ServeUpdateStream is part of the gorpc UpdateStream service

func (*UpdateStream) StreamKeyRange

func (server *UpdateStream) StreamKeyRange(req *proto.KeyRangeRequest, sendReply func(reply interface{}) error) (err error)

StreamKeyRange is part of the gorpc UpdateStream service

func (*UpdateStream) StreamTables

func (server *UpdateStream) StreamTables(req *proto.TablesRequest, sendReply func(reply interface{}) error) (err error)

StreamTables is part of the gorpc UpdateStream service