streaming

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
  • func NewHelloClient(cc *grpc.ClientConn) 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
  • func NewHelloYARPCClient(clientConfig transport.ClientConfig, options ...protobuf.ClientOption) HelloYARPCClient
• type HelloYARPCServer
• type Hello_HelloInStreamClient
• type Hello_HelloInStreamServer
• type Hello_HelloOutStreamClient
• type Hello_HelloOutStreamServer
• type Hello_HelloThereClient
• type Hello_HelloThereServer

Variables

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) MarshalTo

func (m *HelloRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo

func (m *HelloResponse) MarshalTo(dAtA []byte) (int, 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
}