Versions in this module Expand all Collapse all v2 v2.1.4 Mar 15, 2023 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
Go to main page