gorpcbinlogplayer

Documentation

Index

• type GoRpcBinlogPlayerClient
  • func (client *GoRpcBinlogPlayerClient) Close()
  • func (client *GoRpcBinlogPlayerClient) Dial(addr string, connTimeout time.Duration) error
  • func (client *GoRpcBinlogPlayerClient) ServeUpdateStream(req *proto.UpdateStreamRequest, responseChan chan *proto.StreamEvent) binlogplayer.BinlogPlayerResponse
  • func (client *GoRpcBinlogPlayerClient) StreamKeyRange(req *proto.KeyRangeRequest, responseChan chan *proto.BinlogTransaction) binlogplayer.BinlogPlayerResponse
  • func (client *GoRpcBinlogPlayerClient) StreamTables(req *proto.TablesRequest, responseChan chan *proto.BinlogTransaction) binlogplayer.BinlogPlayerResponse
• type GoRpcBinlogPlayerResponse
  • func (response *GoRpcBinlogPlayerResponse) Error() error

Types

type GoRpcBinlogPlayerClient

type GoRpcBinlogPlayerClient struct {
	*rpcplus.Client
}

GoRpcBinlogPlayerClient implements a BinlogPlayerClient over go rpc

func (*GoRpcBinlogPlayerClient) Close

func (client *GoRpcBinlogPlayerClient) Close()

func (*GoRpcBinlogPlayerClient) Dial

func (client *GoRpcBinlogPlayerClient) Dial(addr string, connTimeout time.Duration) error

func (*GoRpcBinlogPlayerClient) ServeUpdateStream

func (client *GoRpcBinlogPlayerClient) ServeUpdateStream(req *proto.UpdateStreamRequest, responseChan chan *proto.StreamEvent) binlogplayer.BinlogPlayerResponse

func (*GoRpcBinlogPlayerClient) StreamKeyRange

func (client *GoRpcBinlogPlayerClient) StreamKeyRange(req *proto.KeyRangeRequest, responseChan chan *proto.BinlogTransaction) binlogplayer.BinlogPlayerResponse

func (*GoRpcBinlogPlayerClient) StreamTables

func (client *GoRpcBinlogPlayerClient) StreamTables(req *proto.TablesRequest, responseChan chan *proto.BinlogTransaction) binlogplayer.BinlogPlayerResponse

type GoRpcBinlogPlayerResponse

type GoRpcBinlogPlayerResponse struct {
	*rpcplus.Call
}

GoRpcBinlogPlayerResponse is the type returned by the Client for streaming

func (*GoRpcBinlogPlayerResponse) Error

func (response *GoRpcBinlogPlayerResponse) Error() error