proto

Nov 30, 2022

Changes in this version

+ var File_proto_v1beta_sink_proto protoreflect.FileDescriptor

+ var SinkService_ServiceDesc = grpc.ServiceDesc

+ func RegisterSinkServiceServer(s grpc.ServiceRegistrar, srv SinkServiceServer)

+ type SendRequest struct

+ Data []byte

+ Metadata []byte

+ func (*SendRequest) Descriptor() ([]byte, []int)

+ func (*SendRequest) ProtoMessage()

+ func (x *SendRequest) GetData() []byte

+ func (x *SendRequest) GetMetadata() []byte

+ func (x *SendRequest) ProtoReflect() protoreflect.Message

+ func (x *SendRequest) Reset()

+ func (x *SendRequest) String() string

+ type SendResponse struct

+ func (*SendResponse) Descriptor() ([]byte, []int)

+ func (*SendResponse) ProtoMessage()

+ func (x *SendResponse) ProtoReflect() protoreflect.Message

+ func (x *SendResponse) Reset()

+ func (x *SendResponse) String() string

+ type SinkServiceClient interface

+ Send func(ctx context.Context, opts ...grpc.CallOption) (SinkService_SendClient, error)

+ func NewSinkServiceClient(cc grpc.ClientConnInterface) SinkServiceClient

+ type SinkServiceServer interface

+ Send func(SinkService_SendServer) error

+ type SinkService_SendClient interface

+ CloseAndRecv func() (*SendResponse, error)

+ Send func(*SendRequest) error

+ type SinkService_SendServer interface

+ Recv func() (*SendRequest, error)

+ SendAndClose func(*SendResponse) error

+ type UnimplementedSinkServiceServer struct

+ func (UnimplementedSinkServiceServer) Send(SinkService_SendServer) error

+ type UnsafeSinkServiceServer interface