devgrpc

Documentation

Index

• Constants
• Variables
• func RegisterUpdateStreamServer(s grpc.ServiceRegistrar, srv UpdateStreamServer)
• type UnimplementedUpdateStreamServer
  • func (UnimplementedUpdateStreamServer) StreamKeyRange(*dev.StreamKeyRangeRequest, ...) error
  • func (UnimplementedUpdateStreamServer) StreamTables(*dev.StreamTablesRequest, grpc.ServerStreamingServer[dev.StreamTablesResponse]) 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

Constants

const (
	UpdateStream_StreamKeyRange_FullMethodName = "/vitess.binlogservice.dev.UpdateStream/StreamKeyRange"
	UpdateStream_StreamTables_FullMethodName   = "/vitess.binlogservice.dev.UpdateStream/StreamTables"
)

Variables

var UpdateStream_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "vitess.binlogservice.dev.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: "vitess/binlogservice/dev/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 should be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedUpdateStreamServer) StreamKeyRange

func (UnimplementedUpdateStreamServer) StreamKeyRange(*dev.StreamKeyRangeRequest, grpc.ServerStreamingServer[dev.StreamKeyRangeResponse]) error

func (UnimplementedUpdateStreamServer) StreamTables

func (UnimplementedUpdateStreamServer) StreamTables(*dev.StreamTablesRequest, grpc.ServerStreamingServer[dev.StreamTablesResponse]) 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 *dev.StreamKeyRangeRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[dev.StreamKeyRangeResponse], error)
	// StreamTables returns the binlog transactions related to
	// the specified Tables.
	StreamTables(ctx context.Context, in *dev.StreamTablesRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[dev.StreamTablesResponse], 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.

UpdateStream is the RPC version of binlog.UpdateStream.

func NewUpdateStreamClient

func NewUpdateStreamClient(cc grpc.ClientConnInterface) UpdateStreamClient

type UpdateStreamServer

type UpdateStreamServer interface {
	// StreamKeyRange returns the binlog transactions related to
	// the specified Keyrange.
	StreamKeyRange(*dev.StreamKeyRangeRequest, grpc.ServerStreamingServer[dev.StreamKeyRangeResponse]) error
	// StreamTables returns the binlog transactions related to
	// the specified Tables.
	StreamTables(*dev.StreamTablesRequest, grpc.ServerStreamingServer[dev.StreamTablesResponse]) error
}

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

UpdateStream is the RPC version of binlog.UpdateStream.

type UpdateStream_StreamKeyRangeClient

type UpdateStream_StreamKeyRangeClient = grpc.ServerStreamingClient[dev.StreamKeyRangeResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type UpdateStream_StreamKeyRangeServer

type UpdateStream_StreamKeyRangeServer = grpc.ServerStreamingServer[dev.StreamKeyRangeResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type UpdateStream_StreamTablesClient

type UpdateStream_StreamTablesClient = grpc.ServerStreamingClient[dev.StreamTablesResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type UpdateStream_StreamTablesServer

type UpdateStream_StreamTablesServer = grpc.ServerStreamingServer[dev.StreamTablesResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.