var File_github_com_containerd_ttrpc_integration_streaming_test_proto protoreflect.FileDescriptor
func RegisterTTRPCStreamingService(srv *ttrpc.Server, svc TTRPCStreamingService)
type EchoPayload struct {
Seq uint32 `protobuf:"varint,1,opt,name=seq,proto3" json:"seq,omitempty"`
Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
// contains filtered or unexported fields
}
func (*EchoPayload) Descriptor() ([]byte, []int)
Deprecated: Use EchoPayload.ProtoReflect.Descriptor instead.
func (x *EchoPayload) GetMsg() string
func (x *EchoPayload) GetSeq() uint32
func (*EchoPayload) ProtoMessage()
func (x *EchoPayload) ProtoReflect() protoreflect.Message
func (x *EchoPayload) Reset()
func (x *EchoPayload) String() string
type Part struct {
Add int32 `protobuf:"varint,1,opt,name=add,proto3" json:"add,omitempty"`
// contains filtered or unexported fields
}
func (*Part) Descriptor() ([]byte, []int)
Deprecated: Use Part.ProtoReflect.Descriptor instead.
func (x *Part) GetAdd() int32
func (*Part) ProtoMessage()
func (x *Part) ProtoReflect() protoreflect.Message
func (x *Part) Reset()
func (x *Part) String() string
type Sum struct {
Sum int32 `protobuf:"varint,1,opt,name=sum,proto3" json:"sum,omitempty"`
Num int32 `protobuf:"varint,2,opt,name=num,proto3" json:"num,omitempty"`
// contains filtered or unexported fields
}
func (*Sum) Descriptor() ([]byte, []int)
Deprecated: Use Sum.ProtoReflect.Descriptor instead.
func (x *Sum) GetNum() int32
func (x *Sum) GetSum() int32
func (*Sum) ProtoMessage()
func (x *Sum) ProtoReflect() protoreflect.Message
func (x *Sum) Reset()
func (x *Sum) String() string
type TTRPCStreamingClient interface {
Echo(context.Context, *EchoPayload) (*EchoPayload, error)
EchoStream(context.Context) (TTRPCStreaming_EchoStreamClient, error)
SumStream(context.Context) (TTRPCStreaming_SumStreamClient, error)
DivideStream(context.Context, *Sum) (TTRPCStreaming_DivideStreamClient, error)
EchoNull(context.Context) (TTRPCStreaming_EchoNullClient, error)
EchoNullStream(context.Context) (TTRPCStreaming_EchoNullStreamClient, error)
}
func NewTTRPCStreamingClient(client *ttrpc.Client) TTRPCStreamingClient
type TTRPCStreamingService interface {
Echo(context.Context, *EchoPayload) (*EchoPayload, error)
EchoStream(context.Context, TTRPCStreaming_EchoStreamServer) error
SumStream(context.Context, TTRPCStreaming_SumStreamServer) (*Sum, error)
DivideStream(context.Context, *Sum, TTRPCStreaming_DivideStreamServer) error
EchoNull(context.Context, TTRPCStreaming_EchoNullServer) (*emptypb.Empty, error)
EchoNullStream(context.Context, TTRPCStreaming_EchoNullStreamServer) error
}
type TTRPCStreaming_DivideStreamClient interface {
Recv() (*Part, error)
ttrpc.ClientStream
}
type TTRPCStreaming_DivideStreamServer interface {
Send(*Part) error
ttrpc.StreamServer
}
type TTRPCStreaming_EchoNullClient interface {
Send(*EchoPayload) error
CloseAndRecv() (*emptypb.Empty, error)
ttrpc.ClientStream
}
type TTRPCStreaming_EchoNullServer interface {
Recv() (*EchoPayload, error)
ttrpc.StreamServer
}
type TTRPCStreaming_EchoNullStreamClient interface {
Send(*EchoPayload) error
Recv() (*emptypb.Empty, error)
ttrpc.ClientStream
}
type TTRPCStreaming_EchoNullStreamServer interface {
Send(*emptypb.Empty) error
Recv() (*EchoPayload, error)
ttrpc.StreamServer
}
type TTRPCStreaming_EchoStreamClient interface {
Send(*EchoPayload) error
Recv() (*EchoPayload, error)
ttrpc.ClientStream
}
type TTRPCStreaming_EchoStreamServer interface {
Send(*EchoPayload) error
Recv() (*EchoPayload, error)
ttrpc.StreamServer
}
type TTRPCStreaming_SumStreamClient interface {
Send(*Part) error
CloseAndRecv() (*Sum, error)
ttrpc.ClientStream
}
type TTRPCStreaming_SumStreamServer interface {
Recv() (*Part, error)
ttrpc.StreamServer
}