grpc

Jan 27, 2022

Changes in this version

+ func RegisterBiRequestStreamServer(s *grpc.Server, srv BiRequestStreamServer)

+ func RegisterRequestServer(s *grpc.Server, srv RequestServer)

+ func RegisterRequestStreamServer(s *grpc.Server, srv RequestStreamServer)

+ type BiRequestStreamClient interface

+ RequestBiStream func(ctx context.Context, opts ...grpc.CallOption) (BiRequestStream_RequestBiStreamClient, error)

+ func NewBiRequestStreamClient(cc *grpc.ClientConn) BiRequestStreamClient

+ type BiRequestStreamServer interface

+ RequestBiStream func(BiRequestStream_RequestBiStreamServer) error

+ type BiRequestStream_RequestBiStreamClient interface

+ Recv func() (*Payload, error)

+ Send func(*Payload) error

+ type BiRequestStream_RequestBiStreamServer interface

+ Recv func() (*Payload, error)

+ Send func(*Payload) error

+ type Metadata struct

+ ClientIp string

+ Headers map[string]string

+ Type string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Metadata) ProtoMessage()

+ func (m *Metadata) GetClientIp() string

+ func (m *Metadata) GetHeaders() map[string]string

+ func (m *Metadata) GetType() string

+ func (m *Metadata) Reset()

+ func (m *Metadata) String() string

+ func (m *Metadata) XXX_DiscardUnknown()

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

+ func (m *Metadata) XXX_Merge(src proto.Message)

+ func (m *Metadata) XXX_Size() int

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

+ type Payload struct

+ Body *any.Any

+ Metadata *Metadata

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Payload) ProtoMessage()

+ func (m *Payload) GetBody() *any.Any

+ func (m *Payload) GetMetadata() *Metadata

+ func (m *Payload) Reset()

+ func (m *Payload) String() string

+ func (m *Payload) XXX_DiscardUnknown()

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

+ func (m *Payload) XXX_Merge(src proto.Message)

+ func (m *Payload) XXX_Size() int

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

+ type RequestClient interface

+ Request func(ctx context.Context, in *Payload, opts ...grpc.CallOption) (*Payload, error)

+ func NewRequestClient(cc *grpc.ClientConn) RequestClient

+ type RequestServer interface

+ Request func(context.Context, *Payload) (*Payload, error)

+ type RequestStreamClient interface

+ RequestStream func(ctx context.Context, in *Payload, opts ...grpc.CallOption) (RequestStream_RequestStreamClient, error)

+ func NewRequestStreamClient(cc *grpc.ClientConn) RequestStreamClient

+ type RequestStreamServer interface

+ RequestStream func(*Payload, RequestStream_RequestStreamServer) error

+ type RequestStream_RequestStreamClient interface

+ Recv func() (*Payload, error)

+ type RequestStream_RequestStreamServer interface

+ Send func(*Payload) error

+ type UnimplementedBiRequestStreamServer struct

+ func (*UnimplementedBiRequestStreamServer) RequestBiStream(srv BiRequestStream_RequestBiStreamServer) error

+ type UnimplementedRequestServer struct

+ func (*UnimplementedRequestServer) Request(ctx context.Context, req *Payload) (*Payload, error)

+ type UnimplementedRequestStreamServer struct

+ func (*UnimplementedRequestStreamServer) RequestStream(req *Payload, srv RequestStream_RequestStreamServer) error