Documentation
¶
Index ¶
- Variables
- func RegisterUpdateStreamServer(s grpc.ServiceRegistrar, srv UpdateStreamServer)
- type UnimplementedUpdateStreamServer
- type UnsafeUpdateStreamServer
- type UpdateStreamClient
- type UpdateStreamServer
- type UpdateStream_StreamKeyRangeClient
- type UpdateStream_StreamKeyRangeServer
- type UpdateStream_StreamTablesClient
- type UpdateStream_StreamTablesServer
Constants ¶
This section is empty.
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 ¶ added in v0.11.0
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
}
Source Files