streaming

package

Go to main page

Versions in this module

v1

v1.32.4

Aug 8, 2018

v1.32.3

Aug 8, 2018

v1.32.2

Aug 7, 2018

v1.32.1

Aug 7, 2018

v1.32.0

Aug 6, 2018

Changes in this version

type HelloRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ func (dst *HelloRequest) XXX_Merge(src proto.Message)

+ func (m *HelloRequest) XXX_DiscardUnknown()

+ func (m *HelloRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *HelloRequest) XXX_Size() int

+ func (m *HelloRequest) XXX_Unmarshal(b []byte) error

type HelloResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ func (dst *HelloResponse) XXX_Merge(src proto.Message)

+ func (m *HelloResponse) XXX_DiscardUnknown()

+ func (m *HelloResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *HelloResponse) XXX_Size() int

+ func (m *HelloResponse) XXX_Unmarshal(b []byte) error

v1.31.0

Jul 9, 2018

v1.30.0

May 3, 2018

v1.29.1

Apr 4, 2018

v1.29.0

Mar 21, 2018

Changes in this version

+ func NewFxHelloYARPCClient(name string, options ...protobuf.ClientOption) interface

+ func NewFxHelloYARPCProcedures() interface

+ type FxHelloYARPCClientParams struct

+ Provider yarpc.ClientConfig

+ type FxHelloYARPCClientResult struct

+ Client HelloYARPCClient

+ type FxHelloYARPCProceduresParams struct

+ Server HelloYARPCServer

+ type FxHelloYARPCProceduresResult struct

+ Procedures []transport.Procedure

v1.28.0

Mar 13, 2018

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL