Documentation
¶
Overview ¶
Package streaming is a generated protocol buffer package.
It is generated from these files:
internal/examples/streaming/stream.proto
It has these top-level messages:
HelloRequest HelloResponse
Index ¶
- Variables
- func BuildHelloYARPCProcedures(server HelloYARPCServer) []transport.Procedure
- func RegisterHelloServer(s *grpc.Server, srv HelloServer)
- type HelloClient
- type HelloRequest
- func (*HelloRequest) Descriptor() ([]byte, []int)
- func (this *HelloRequest) Equal(that interface{}) bool
- func (m *HelloRequest) GetId() string
- func (this *HelloRequest) GoString() string
- func (m *HelloRequest) Marshal() (dAtA []byte, err error)
- func (m *HelloRequest) MarshalTo(dAtA []byte) (int, error)
- func (*HelloRequest) ProtoMessage()
- func (m *HelloRequest) Reset()
- func (m *HelloRequest) Size() (n int)
- func (this *HelloRequest) String() string
- func (m *HelloRequest) Unmarshal(dAtA []byte) error
- type HelloResponse
- func (*HelloResponse) Descriptor() ([]byte, []int)
- func (this *HelloResponse) Equal(that interface{}) bool
- func (m *HelloResponse) GetId() string
- func (this *HelloResponse) GoString() string
- func (m *HelloResponse) Marshal() (dAtA []byte, err error)
- func (m *HelloResponse) MarshalTo(dAtA []byte) (int, error)
- func (*HelloResponse) ProtoMessage()
- func (m *HelloResponse) Reset()
- func (m *HelloResponse) Size() (n int)
- func (this *HelloResponse) String() string
- func (m *HelloResponse) Unmarshal(dAtA []byte) error
- type HelloServer
- type HelloServiceHelloInStreamYARPCClient
- type HelloServiceHelloInStreamYARPCServer
- type HelloServiceHelloOutStreamYARPCClient
- type HelloServiceHelloOutStreamYARPCServer
- type HelloServiceHelloThereYARPCClient
- type HelloServiceHelloThereYARPCServer
- type HelloYARPCClient
- type HelloYARPCServer
- type Hello_HelloInStreamClient
- type Hello_HelloInStreamServer
- type Hello_HelloOutStreamClient
- type Hello_HelloOutStreamServer
- type Hello_HelloThereClient
- type Hello_HelloThereServer
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthStream = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowStream = fmt.Errorf("proto: integer overflow") )
Functions ¶
func BuildHelloYARPCProcedures ¶
func BuildHelloYARPCProcedures(server HelloYARPCServer) []transport.Procedure
BuildHelloYARPCProcedures prepares an implementation of the Hello service for YARPC registration.
func RegisterHelloServer ¶
func RegisterHelloServer(s *grpc.Server, srv HelloServer)
Types ¶
type HelloClient ¶
type HelloClient interface {
HelloUnary(ctx context.Context, in *HelloRequest, opts ...grpc.CallOption) (*HelloResponse, error)
HelloThere(ctx context.Context, opts ...grpc.CallOption) (Hello_HelloThereClient, error)
HelloOutStream(ctx context.Context, opts ...grpc.CallOption) (Hello_HelloOutStreamClient, error)
HelloInStream(ctx context.Context, in *HelloRequest, opts ...grpc.CallOption) (Hello_HelloInStreamClient, error)
}
func NewHelloClient ¶
func NewHelloClient(cc *grpc.ClientConn) HelloClient
type HelloRequest ¶
type HelloRequest struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
}
func (*HelloRequest) Descriptor ¶
func (*HelloRequest) Descriptor() ([]byte, []int)
func (*HelloRequest) Equal ¶
func (this *HelloRequest) Equal(that interface{}) bool
func (*HelloRequest) GetId ¶
func (m *HelloRequest) GetId() string
func (*HelloRequest) GoString ¶
func (this *HelloRequest) GoString() string
func (*HelloRequest) Marshal ¶
func (m *HelloRequest) Marshal() (dAtA []byte, err error)
func (*HelloRequest) ProtoMessage ¶
func (*HelloRequest) ProtoMessage()
func (*HelloRequest) Reset ¶
func (m *HelloRequest) Reset()
func (*HelloRequest) Size ¶
func (m *HelloRequest) Size() (n int)
func (*HelloRequest) String ¶
func (this *HelloRequest) String() string
func (*HelloRequest) Unmarshal ¶
func (m *HelloRequest) Unmarshal(dAtA []byte) error
type HelloResponse ¶
type HelloResponse struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
}
func (*HelloResponse) Descriptor ¶
func (*HelloResponse) Descriptor() ([]byte, []int)
func (*HelloResponse) Equal ¶
func (this *HelloResponse) Equal(that interface{}) bool
func (*HelloResponse) GetId ¶
func (m *HelloResponse) GetId() string
func (*HelloResponse) GoString ¶
func (this *HelloResponse) GoString() string
func (*HelloResponse) Marshal ¶
func (m *HelloResponse) Marshal() (dAtA []byte, err error)
func (*HelloResponse) ProtoMessage ¶
func (*HelloResponse) ProtoMessage()
func (*HelloResponse) Reset ¶
func (m *HelloResponse) Reset()
func (*HelloResponse) Size ¶
func (m *HelloResponse) Size() (n int)
func (*HelloResponse) String ¶
func (this *HelloResponse) String() string
func (*HelloResponse) Unmarshal ¶
func (m *HelloResponse) Unmarshal(dAtA []byte) error
type HelloServer ¶
type HelloServer interface {
HelloUnary(context.Context, *HelloRequest) (*HelloResponse, error)
HelloThere(Hello_HelloThereServer) error
HelloOutStream(Hello_HelloOutStreamServer) error
HelloInStream(*HelloRequest, Hello_HelloInStreamServer) error
}
type HelloServiceHelloInStreamYARPCClient ¶
type HelloServiceHelloInStreamYARPCClient interface {
Context() context.Context
Recv(...yarpc.StreamOption) (*HelloResponse, error)
CloseSend(...yarpc.StreamOption) error
}
HelloServiceHelloInStreamYARPCClient receives HelloResponses, returning io.EOF when the stream is complete.
type HelloServiceHelloInStreamYARPCServer ¶
type HelloServiceHelloInStreamYARPCServer interface {
Context() context.Context
Send(*HelloResponse, ...yarpc.StreamOption) error
}
HelloServiceHelloInStreamYARPCServer sends HelloResponses.
type HelloServiceHelloOutStreamYARPCClient ¶
type HelloServiceHelloOutStreamYARPCClient interface {
Context() context.Context
Send(*HelloRequest, ...yarpc.StreamOption) error
CloseAndRecv(...yarpc.StreamOption) (*HelloResponse, error)
}
HelloServiceHelloOutStreamYARPCClient sends HelloRequests and receives the single HelloResponse when sending is done.
type HelloServiceHelloOutStreamYARPCServer ¶
type HelloServiceHelloOutStreamYARPCServer interface {
Context() context.Context
Recv(...yarpc.StreamOption) (*HelloRequest, error)
}
HelloServiceHelloOutStreamYARPCServer receives HelloRequests.
type HelloServiceHelloThereYARPCClient ¶
type HelloServiceHelloThereYARPCClient interface {
Context() context.Context
Send(*HelloRequest, ...yarpc.StreamOption) error
Recv(...yarpc.StreamOption) (*HelloResponse, error)
CloseSend(...yarpc.StreamOption) error
}
HelloServiceHelloThereYARPCClient sends HelloRequests and receives HelloResponses, returning io.EOF when the stream is complete.
type HelloServiceHelloThereYARPCServer ¶
type HelloServiceHelloThereYARPCServer interface {
Context() context.Context
Recv(...yarpc.StreamOption) (*HelloRequest, error)
Send(*HelloResponse, ...yarpc.StreamOption) error
}
HelloServiceHelloThereYARPCServer receives HelloRequests and sends HelloResponse.
type HelloYARPCClient ¶
type HelloYARPCClient interface {
HelloUnary(context.Context, *HelloRequest, ...yarpc.CallOption) (*HelloResponse, error)
HelloOutStream(context.Context, ...yarpc.CallOption) (HelloServiceHelloOutStreamYARPCClient, error)
HelloInStream(context.Context, *HelloRequest, ...yarpc.CallOption) (HelloServiceHelloInStreamYARPCClient, error)
HelloThere(context.Context, ...yarpc.CallOption) (HelloServiceHelloThereYARPCClient, error)
}
HelloYARPCClient is the YARPC client-side interface for the Hello service.
func NewHelloYARPCClient ¶
func NewHelloYARPCClient(clientConfig transport.ClientConfig, options ...protobuf.ClientOption) HelloYARPCClient
NewHelloYARPCClient builds a new YARPC client for the Hello service.
type HelloYARPCServer ¶
type HelloYARPCServer interface {
HelloUnary(context.Context, *HelloRequest) (*HelloResponse, error)
HelloOutStream(HelloServiceHelloOutStreamYARPCServer) (*HelloResponse, error)
HelloInStream(*HelloRequest, HelloServiceHelloInStreamYARPCServer) error
HelloThere(HelloServiceHelloThereYARPCServer) error
}
HelloYARPCServer is the YARPC server-side interface for the Hello service.
type Hello_HelloInStreamClient ¶
type Hello_HelloInStreamClient interface {
Recv() (*HelloResponse, error)
grpc.ClientStream
}
type Hello_HelloInStreamServer ¶
type Hello_HelloInStreamServer interface {
Send(*HelloResponse) error
grpc.ServerStream
}
type Hello_HelloOutStreamClient ¶
type Hello_HelloOutStreamClient interface {
Send(*HelloRequest) error
CloseAndRecv() (*HelloResponse, error)
grpc.ClientStream
}
type Hello_HelloOutStreamServer ¶
type Hello_HelloOutStreamServer interface {
SendAndClose(*HelloResponse) error
Recv() (*HelloRequest, error)
grpc.ServerStream
}
type Hello_HelloThereClient ¶
type Hello_HelloThereClient interface {
Send(*HelloRequest) error
Recv() (*HelloResponse, error)
grpc.ClientStream
}
type Hello_HelloThereServer ¶
type Hello_HelloThereServer interface {
Send(*HelloResponse) error
Recv() (*HelloRequest, error)
grpc.ServerStream
}
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.