binlogservice

Documentation

Overview

Package binlogservice is a generated protocol buffer package.

It is generated from these files:

binlogservice.proto

It has these top-level messages:

Index

• func RegisterUpdateStreamServer(s *grpc.Server, srv UpdateStreamServer)
• type UpdateStreamClient
  • func NewUpdateStreamClient(cc *grpc.ClientConn) UpdateStreamClient
• type UpdateStreamServer
• type UpdateStream_StreamKeyRangeClient
• type UpdateStream_StreamKeyRangeServer
• type UpdateStream_StreamTablesClient
• type UpdateStream_StreamTablesServer
• type UpdateStream_StreamUpdateClient
• type UpdateStream_StreamUpdateServer

Functions

func RegisterUpdateStreamServer

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

Types

type UpdateStreamClient

type UpdateStreamClient interface {
	// StreamUpdate streams the binlog events, to know which objects have changed.
	StreamUpdate(ctx context.Context, in *binlogdata.StreamUpdateRequest, opts ...grpc.CallOption) (UpdateStream_StreamUpdateClient, error)
	// 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)
}

func NewUpdateStreamClient

func NewUpdateStreamClient(cc *grpc.ClientConn) UpdateStreamClient

type UpdateStreamServer

type UpdateStreamServer interface {
	// StreamUpdate streams the binlog events, to know which objects have changed.
	StreamUpdate(*binlogdata.StreamUpdateRequest, UpdateStream_StreamUpdateServer) error
	// 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
}

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
}

type UpdateStream_StreamUpdateClient

type UpdateStream_StreamUpdateClient interface {
	Recv() (*binlogdata.StreamUpdateResponse, error)
	grpc.ClientStream
}

type UpdateStream_StreamUpdateServer

type UpdateStream_StreamUpdateServer interface {
	Send(*binlogdata.StreamUpdateResponse) error
	grpc.ServerStream
}