binlogservice

Documentation

Index

• func RegisterUpdateStreamServer(s *grpc.Server, srv UpdateStreamServer)
• type UnimplementedUpdateStreamServer
  • func (*UnimplementedUpdateStreamServer) StreamKeyRange(req *binlogdata.StreamKeyRangeRequest, srv UpdateStream_StreamKeyRangeServer) error
  • func (*UnimplementedUpdateStreamServer) StreamTables(req *binlogdata.StreamTablesRequest, srv UpdateStream_StreamTablesServer) error
• type UpdateStreamClient
  • func NewUpdateStreamClient(cc *grpc.ClientConn) UpdateStreamClient
• type UpdateStreamServer
• type UpdateStream_StreamKeyRangeClient
• type UpdateStream_StreamKeyRangeServer
• type UpdateStream_StreamTablesClient
• type UpdateStream_StreamTablesServer

Functions

func RegisterUpdateStreamServer

func RegisterUpdateStreamServer(s *grpc.Server, srv UpdateStreamServer)

Types

type UnimplementedUpdateStreamServer

type UnimplementedUpdateStreamServer struct {
}

UnimplementedUpdateStreamServer can be embedded to have forward compatible implementations.

func (*UnimplementedUpdateStreamServer) StreamKeyRange

func (*UnimplementedUpdateStreamServer) StreamKeyRange(req *binlogdata.StreamKeyRangeRequest, srv UpdateStream_StreamKeyRangeServer) error

func (*UnimplementedUpdateStreamServer) StreamTables

func (*UnimplementedUpdateStreamServer) StreamTables(req *binlogdata.StreamTablesRequest, srv UpdateStream_StreamTablesServer) error

type UpdateStreamClient

type UpdateStreamClient interface {
	// StreamKeyRange returns the binlog transactions related to
	// the specified Keyrange.
	StreamKeyRange(ctx context.Context, in *binlogdata.StreamKeyRangeRequest, opts ...grpc.CallOption) (UpdateStream_StreamKeyRangeClient, error)
	// StreamTables returns the binlog transactions related to
	// the specified Tables.
	StreamTables(ctx context.Context, in *binlogdata.StreamTablesRequest, opts ...grpc.CallOption) (UpdateStream_StreamTablesClient, error)
}

UpdateStreamClient is the client API for UpdateStream service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewUpdateStreamClient

func NewUpdateStreamClient(cc *grpc.ClientConn) UpdateStreamClient

type UpdateStreamServer

type UpdateStreamServer interface {
	// StreamKeyRange returns the binlog transactions related to
	// the specified Keyrange.
	StreamKeyRange(*binlogdata.StreamKeyRangeRequest, UpdateStream_StreamKeyRangeServer) error
	// StreamTables returns the binlog transactions related to
	// the specified Tables.
	StreamTables(*binlogdata.StreamTablesRequest, UpdateStream_StreamTablesServer) error
}

UpdateStreamServer is the server API for UpdateStream service.

type UpdateStream_StreamKeyRangeClient

type UpdateStream_StreamKeyRangeClient interface {
	Recv() (*binlogdata.StreamKeyRangeResponse, error)
	grpc.ClientStream
}

type UpdateStream_StreamKeyRangeServer

type UpdateStream_StreamKeyRangeServer interface {
	Send(*binlogdata.StreamKeyRangeResponse) error
	grpc.ServerStream
}

type UpdateStream_StreamTablesClient

type UpdateStream_StreamTablesClient interface {
	Recv() (*binlogdata.StreamTablesResponse, error)
	grpc.ClientStream
}

type UpdateStream_StreamTablesServer

type UpdateStream_StreamTablesServer interface {
	Send(*binlogdata.StreamTablesResponse) error
	grpc.ServerStream
}