proto

Documentation

Index

• Variables
• func RegisterSinkServiceServer(s grpc.ServiceRegistrar, srv SinkServiceServer)
• type SendRequest
  • func (*SendRequest) Descriptor() ([]byte, []int)
  • func (x *SendRequest) GetData() []byte
  • func (x *SendRequest) GetMetadata() []byte
  • func (*SendRequest) ProtoMessage()
  • func (x *SendRequest) ProtoReflect() protoreflect.Message
  • func (x *SendRequest) Reset()
  • func (x *SendRequest) String() string
• type SendResponse
  • 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
  • func NewSinkServiceClient(cc grpc.ClientConnInterface) SinkServiceClient
• type SinkServiceServer
• type SinkService_SendClient
• type SinkService_SendServer
• type UnimplementedSinkServiceServer
  • func (UnimplementedSinkServiceServer) Send(SinkService_SendServer) error
• type UnsafeSinkServiceServer

Variables

var File_proto_v1beta_sink_proto protoreflect.FileDescriptor

var SinkService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.v1beta.SinkService",
	HandlerType: (*SinkServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Send",
			Handler:       _SinkService_Send_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "proto/v1beta/sink.proto",
}

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

Functions

func RegisterSinkServiceServer

func RegisterSinkServiceServer(s grpc.ServiceRegistrar, srv SinkServiceServer)

Types

type SendRequest

type SendRequest struct {
	Data     []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Metadata []byte `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

SendRequest mirrors the Capsule struct defined in config

func (*SendRequest) Descriptor

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

Deprecated: Use SendRequest.ProtoReflect.Descriptor instead.

func (*SendRequest) GetData

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

func (*SendRequest) GetMetadata

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

func (*SendRequest) ProtoMessage

func (*SendRequest) ProtoMessage()

func (*SendRequest) ProtoReflect

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

func (*SendRequest) Reset

func (x *SendRequest) Reset()

func (*SendRequest) String

func (x *SendRequest) String() string

type SendResponse

type SendResponse struct {
	// contains filtered or unexported fields
}

SendResponse is sent by the server to acknowledge successful receipt of all requests

func (*SendResponse) Descriptor

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

Deprecated: Use SendResponse.ProtoReflect.Descriptor instead.

func (*SendResponse) ProtoMessage

func (*SendResponse) ProtoMessage()

func (*SendResponse) ProtoReflect

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

func (*SendResponse) Reset

func (x *SendResponse) Reset()

func (*SendResponse) String

func (x *SendResponse) String() string

type SinkServiceClient

type SinkServiceClient interface {
	Send(ctx context.Context, opts ...grpc.CallOption) (SinkService_SendClient, error)
}

SinkServiceClient is the client API for SinkService 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 NewSinkServiceClient

func NewSinkServiceClient(cc grpc.ClientConnInterface) SinkServiceClient

type SinkServiceServer

type SinkServiceServer interface {
	Send(SinkService_SendServer) error
	// contains filtered or unexported methods
}

SinkServiceServer is the server API for SinkService service. All implementations must embed UnimplementedSinkServiceServer for forward compatibility

type SinkService_SendClient

type SinkService_SendClient interface {
	Send(*SendRequest) error
	CloseAndRecv() (*SendResponse, error)
	grpc.ClientStream
}

type SinkService_SendServer

type SinkService_SendServer interface {
	SendAndClose(*SendResponse) error
	Recv() (*SendRequest, error)
	grpc.ServerStream
}

type UnimplementedSinkServiceServer

type UnimplementedSinkServiceServer struct {
}

UnimplementedSinkServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSinkServiceServer) Send

func (UnimplementedSinkServiceServer) Send(SinkService_SendServer) error

type UnsafeSinkServiceServer

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

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