binlogservice

Documentation

Index

• Variables
• func RegisterUpdateStreamServer(s grpc.ServiceRegistrar, srv UpdateStreamServer)
• type UnimplementedUpdateStreamServer
  • func (UnimplementedUpdateStreamServer) StreamKeyRange(*binlogdata.StreamKeyRangeRequest, UpdateStream_StreamKeyRangeServer) error
  • func (UnimplementedUpdateStreamServer) StreamTables(*binlogdata.StreamTablesRequest, UpdateStream_StreamTablesServer) error
• type UnsafeUpdateStreamServer
• type UpdateStreamClient
  • func NewUpdateStreamClient(cc grpc.ClientConnInterface) UpdateStreamClient
• type UpdateStreamServer
• type UpdateStream_StreamKeyRangeClient
• type UpdateStream_StreamKeyRangeServer
• type UpdateStream_StreamTablesClient
• type UpdateStream_StreamTablesServer

Variables

var File_binlogservice_proto protoreflect.FileDescriptor

var UpdateStream_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "binlogservice.UpdateStream",
	HandlerType: (*UpdateStreamServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamKeyRange",
			Handler:       _UpdateStream_StreamKeyRange_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "StreamTables",
			Handler:       _UpdateStream_StreamTables_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "binlogservice.proto",
}

UpdateStream_ServiceDesc is the grpc.ServiceDesc for UpdateStream service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterUpdateStreamServer

func RegisterUpdateStreamServer(s grpc.ServiceRegistrar, srv UpdateStreamServer)

Types

type UnimplementedUpdateStreamServer

type UnimplementedUpdateStreamServer struct {
}

UnimplementedUpdateStreamServer must be embedded to have forward compatible implementations.

func (UnimplementedUpdateStreamServer) StreamKeyRange

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

func (UnimplementedUpdateStreamServer) StreamTables

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

type UnsafeUpdateStreamServer

type UnsafeUpdateStreamServer interface {
	// contains filtered or unexported methods
}

UnsafeUpdateStreamServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to UpdateStreamServer will result in compilation errors.

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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewUpdateStreamClient

func NewUpdateStreamClient(cc grpc.ClientConnInterface) 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
	// contains filtered or unexported methods
}

UpdateStreamServer is the server API for UpdateStream service. All implementations must embed UnimplementedUpdateStreamServer for forward compatibility

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
}