Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

streaming

package

Go to main page

Versions in this module

v1

v1.27.2

Jan 23, 2018

v1.27.1

Jan 23, 2018

v1.27.0

Jan 22, 2018

Changes in this version

+ var ErrIntOverflowStream = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthStream = fmt.Errorf("proto: negative length found during unmarshaling")

+ func BuildHelloYARPCProcedures(server HelloYARPCServer) []transport.Procedure

+ func RegisterHelloServer(s *grpc.Server, srv HelloServer)

+ type HelloClient interface

+ HelloInStream func(ctx context.Context, in *HelloRequest, opts ...grpc.CallOption) (Hello_HelloInStreamClient, error)

+ HelloOutStream func(ctx context.Context, opts ...grpc.CallOption) (Hello_HelloOutStreamClient, error)

+ HelloThere func(ctx context.Context, opts ...grpc.CallOption) (Hello_HelloThereClient, error)

+ HelloUnary func(ctx context.Context, in *HelloRequest, opts ...grpc.CallOption) (*HelloResponse, error)

+ func NewHelloClient(cc *grpc.ClientConn) HelloClient

+ type HelloRequest struct

+ Id string

+ func (*HelloRequest) Descriptor() ([]byte, []int)

+ func (*HelloRequest) ProtoMessage()

+ func (m *HelloRequest) GetId() string

+ func (m *HelloRequest) Marshal() (dAtA []byte, err error)

+ func (m *HelloRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *HelloRequest) Reset()

+ func (m *HelloRequest) Size() (n int)

+ func (m *HelloRequest) Unmarshal(dAtA []byte) error

+ func (this *HelloRequest) Equal(that interface{}) bool

+ func (this *HelloRequest) GoString() string

+ func (this *HelloRequest) String() string

+ type HelloResponse struct

+ Id string

+ func (*HelloResponse) Descriptor() ([]byte, []int)

+ func (*HelloResponse) ProtoMessage()

+ func (m *HelloResponse) GetId() string

+ func (m *HelloResponse) Marshal() (dAtA []byte, err error)

+ func (m *HelloResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *HelloResponse) Reset()

+ func (m *HelloResponse) Size() (n int)

+ func (m *HelloResponse) Unmarshal(dAtA []byte) error

+ func (this *HelloResponse) Equal(that interface{}) bool

+ func (this *HelloResponse) GoString() string

+ func (this *HelloResponse) String() string

+ type HelloServer interface

+ HelloInStream func(*HelloRequest, Hello_HelloInStreamServer) error

+ HelloOutStream func(Hello_HelloOutStreamServer) error

+ HelloThere func(Hello_HelloThereServer) error

+ HelloUnary func(context.Context, *HelloRequest) (*HelloResponse, error)

+ type HelloServiceHelloInStreamYARPCClient interface

+ CloseSend func(...yarpc.StreamOption) error

+ Context func() context.Context

+ Recv func(...yarpc.StreamOption) (*HelloResponse, error)

+ type HelloServiceHelloInStreamYARPCServer interface

+ Context func() context.Context

+ Send func(*HelloResponse, ...yarpc.StreamOption) error

+ type HelloServiceHelloOutStreamYARPCClient interface

+ CloseAndRecv func(...yarpc.StreamOption) (*HelloResponse, error)

+ Context func() context.Context

+ Send func(*HelloRequest, ...yarpc.StreamOption) error

+ type HelloServiceHelloOutStreamYARPCServer interface

+ Context func() context.Context

+ Recv func(...yarpc.StreamOption) (*HelloRequest, error)

+ type HelloServiceHelloThereYARPCClient interface

+ CloseSend func(...yarpc.StreamOption) error

+ Context func() context.Context

+ Recv func(...yarpc.StreamOption) (*HelloResponse, error)

+ Send func(*HelloRequest, ...yarpc.StreamOption) error

+ type HelloServiceHelloThereYARPCServer interface

+ Context func() context.Context

+ Recv func(...yarpc.StreamOption) (*HelloRequest, error)

+ Send func(*HelloResponse, ...yarpc.StreamOption) error

+ type HelloYARPCClient interface

+ HelloInStream func(context.Context, *HelloRequest, ...yarpc.CallOption) (HelloServiceHelloInStreamYARPCClient, error)

+ HelloOutStream func(context.Context, ...yarpc.CallOption) (HelloServiceHelloOutStreamYARPCClient, error)

+ HelloThere func(context.Context, ...yarpc.CallOption) (HelloServiceHelloThereYARPCClient, error)

+ HelloUnary func(context.Context, *HelloRequest, ...yarpc.CallOption) (*HelloResponse, error)

+ func NewHelloYARPCClient(clientConfig transport.ClientConfig, options ...protobuf.ClientOption) HelloYARPCClient

+ type HelloYARPCServer interface

+ HelloInStream func(*HelloRequest, HelloServiceHelloInStreamYARPCServer) error

+ HelloOutStream func(HelloServiceHelloOutStreamYARPCServer) (*HelloResponse, error)

+ HelloThere func(HelloServiceHelloThereYARPCServer) error

+ HelloUnary func(context.Context, *HelloRequest) (*HelloResponse, error)

+ type Hello_HelloInStreamClient interface

+ Recv func() (*HelloResponse, error)

+ type Hello_HelloInStreamServer interface

+ Send func(*HelloResponse) error

+ type Hello_HelloOutStreamClient interface

+ CloseAndRecv func() (*HelloResponse, error)

+ Send func(*HelloRequest) error

+ type Hello_HelloOutStreamServer interface

+ Recv func() (*HelloRequest, error)

+ SendAndClose func(*HelloResponse) error

+ type Hello_HelloThereClient interface

+ Recv func() (*HelloResponse, error)

+ Send func(*HelloRequest) error

+ type Hello_HelloThereServer interface

+ Recv func() (*HelloRequest, error)

+ Send func(*HelloResponse) error