streaming

Documentation

Overview

Code generated by protoc-gen-go-ttrpc. DO NOT EDIT. source: github.com/containerd/ttrpc/integration/streaming/test.proto

Index

• Variables
• func RegisterTTRPCStreamingService(srv *ttrpc.Server, svc TTRPCStreamingService)
• type EchoPayload
  • func (*EchoPayload) Descriptor() ([]byte, []int)
  • 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
  • func (*Part) Descriptor() ([]byte, []int)
  • 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
  • func (*Sum) Descriptor() ([]byte, []int)
  • 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
  • func NewTTRPCStreamingClient(client *ttrpc.Client) TTRPCStreamingClient
• type TTRPCStreamingService
• type TTRPCStreaming_DivideStreamClient
• type TTRPCStreaming_DivideStreamServer
• type TTRPCStreaming_EchoNullClient
• type TTRPCStreaming_EchoNullServer
• type TTRPCStreaming_EchoNullStreamClient
• type TTRPCStreaming_EchoNullStreamServer
• type TTRPCStreaming_EchoStreamClient
• type TTRPCStreaming_EchoStreamServer
• type TTRPCStreaming_EmptyPayloadStreamClient
• type TTRPCStreaming_EmptyPayloadStreamServer
• type TTRPCStreaming_SumStreamClient
• type TTRPCStreaming_SumStreamServer

Variables

var File_github_com_containerd_ttrpc_integration_streaming_test_proto protoreflect.FileDescriptor

Functions

func RegisterTTRPCStreamingService

func RegisterTTRPCStreamingService(srv *ttrpc.Server, svc TTRPCStreamingService)

Types

type EchoPayload

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

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

Deprecated: Use EchoPayload.ProtoReflect.Descriptor instead.

func (*EchoPayload) GetMsg

func (x *EchoPayload) GetMsg() string

func (*EchoPayload) GetSeq

func (x *EchoPayload) GetSeq() uint32

func (*EchoPayload) ProtoMessage

func (*EchoPayload) ProtoMessage()

func (*EchoPayload) ProtoReflect

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

func (*EchoPayload) Reset

func (x *EchoPayload) Reset()

func (*EchoPayload) String

func (x *EchoPayload) String() string

type Part

type Part struct {
	Add int32 `protobuf:"varint,1,opt,name=add,proto3" json:"add,omitempty"`
	// contains filtered or unexported fields
}

func (*Part) Descriptor

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

Deprecated: Use Part.ProtoReflect.Descriptor instead.

func (*Part) GetAdd

func (x *Part) GetAdd() int32

func (*Part) ProtoMessage

func (*Part) ProtoMessage()

func (*Part) ProtoReflect

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

func (*Part) Reset

func (x *Part) Reset()

func (*Part) String

func (x *Part) String() string

type Sum

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

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

Deprecated: Use Sum.ProtoReflect.Descriptor instead.

func (*Sum) GetNum

func (x *Sum) GetNum() int32

func (*Sum) GetSum

func (x *Sum) GetSum() int32

func (*Sum) ProtoMessage

func (*Sum) ProtoMessage()

func (*Sum) ProtoReflect

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

func (*Sum) Reset

func (x *Sum) Reset()

func (*Sum) String

func (x *Sum) String() string

type TTRPCStreamingClient

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)
	EmptyPayloadStream(context.Context, *emptypb.Empty) (TTRPCStreaming_EmptyPayloadStreamClient, error)
}

func NewTTRPCStreamingClient

func NewTTRPCStreamingClient(client *ttrpc.Client) TTRPCStreamingClient

type TTRPCStreamingService

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
	EmptyPayloadStream(context.Context, *emptypb.Empty, TTRPCStreaming_EmptyPayloadStreamServer) error
}

type TTRPCStreaming_DivideStreamClient

type TTRPCStreaming_DivideStreamClient interface {
	Recv() (*Part, error)
	ttrpc.ClientStream
}

type TTRPCStreaming_DivideStreamServer

type TTRPCStreaming_DivideStreamServer interface {
	Send(*Part) error
	ttrpc.StreamServer
}

type TTRPCStreaming_EchoNullClient

type TTRPCStreaming_EchoNullClient interface {
	Send(*EchoPayload) error
	CloseAndRecv() (*emptypb.Empty, error)
	ttrpc.ClientStream
}

type TTRPCStreaming_EchoNullServer

type TTRPCStreaming_EchoNullServer interface {
	Recv() (*EchoPayload, error)
	ttrpc.StreamServer
}

type TTRPCStreaming_EchoNullStreamClient

type TTRPCStreaming_EchoNullStreamClient interface {
	Send(*EchoPayload) error
	Recv() (*emptypb.Empty, error)
	ttrpc.ClientStream
}

type TTRPCStreaming_EchoNullStreamServer

type TTRPCStreaming_EchoNullStreamServer interface {
	Send(*emptypb.Empty) error
	Recv() (*EchoPayload, error)
	ttrpc.StreamServer
}

type TTRPCStreaming_EchoStreamClient

type TTRPCStreaming_EchoStreamClient interface {
	Send(*EchoPayload) error
	Recv() (*EchoPayload, error)
	ttrpc.ClientStream
}

type TTRPCStreaming_EchoStreamServer

type TTRPCStreaming_EchoStreamServer interface {
	Send(*EchoPayload) error
	Recv() (*EchoPayload, error)
	ttrpc.StreamServer
}

type TTRPCStreaming_EmptyPayloadStreamClient

type TTRPCStreaming_EmptyPayloadStreamClient interface {
	Recv() (*EchoPayload, error)
	ttrpc.ClientStream
}

type TTRPCStreaming_EmptyPayloadStreamServer

type TTRPCStreaming_EmptyPayloadStreamServer interface {
	Send(*EchoPayload) error
	ttrpc.StreamServer
}

type TTRPCStreaming_SumStreamClient

type TTRPCStreaming_SumStreamClient interface {
	Send(*Part) error
	CloseAndRecv() (*Sum, error)
	ttrpc.ClientStream
}

type TTRPCStreaming_SumStreamServer

type TTRPCStreaming_SumStreamServer interface {
	Recv() (*Part, error)
	ttrpc.StreamServer
}