Versions in this module Expand all Collapse all v2 v2.9.3 Mar 19, 2021 Changes in this version + func NewServerEndpoints() []*api.Endpoint + func RegisterServerHandler(s server.Server, hdlr ServerHandler, opts ...server.HandlerOption) error + func RegisterServerServer(s *grpc.Server, srv ServerServer) + type HandleRequest struct + Endpoint string + Protocol string + Service string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*HandleRequest) Descriptor() ([]byte, []int) + func (*HandleRequest) ProtoMessage() + func (m *HandleRequest) GetEndpoint() string + func (m *HandleRequest) GetProtocol() string + func (m *HandleRequest) GetService() string + func (m *HandleRequest) Reset() + func (m *HandleRequest) String() string + func (m *HandleRequest) XXX_DiscardUnknown() + func (m *HandleRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *HandleRequest) XXX_Merge(src proto.Message) + func (m *HandleRequest) XXX_Size() int + func (m *HandleRequest) XXX_Unmarshal(b []byte) error + type HandleResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*HandleResponse) Descriptor() ([]byte, []int) + func (*HandleResponse) ProtoMessage() + func (m *HandleResponse) Reset() + func (m *HandleResponse) String() string + func (m *HandleResponse) XXX_DiscardUnknown() + func (m *HandleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *HandleResponse) XXX_Merge(src proto.Message) + func (m *HandleResponse) XXX_Size() int + func (m *HandleResponse) XXX_Unmarshal(b []byte) error + type ServerClient interface + Handle func(ctx context.Context, in *HandleRequest, opts ...grpc.CallOption) (*HandleResponse, error) + Subscribe func(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (*SubscribeResponse, error) + func NewServerClient(cc *grpc.ClientConn) ServerClient + type ServerHandler interface + Handle func(context.Context, *HandleRequest, *HandleResponse) error + Subscribe func(context.Context, *SubscribeRequest, *SubscribeResponse) error + type ServerServer interface + Handle func(context.Context, *HandleRequest) (*HandleResponse, error) + Subscribe func(context.Context, *SubscribeRequest) (*SubscribeResponse, error) + type ServerService interface + Handle func(ctx context.Context, in *HandleRequest, opts ...client.CallOption) (*HandleResponse, error) + Subscribe func(ctx context.Context, in *SubscribeRequest, opts ...client.CallOption) (*SubscribeResponse, error) + func NewServerService(name string, c client.Client) ServerService + type SubscribeRequest struct + Topic string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SubscribeRequest) Descriptor() ([]byte, []int) + func (*SubscribeRequest) ProtoMessage() + func (m *SubscribeRequest) GetTopic() string + func (m *SubscribeRequest) Reset() + func (m *SubscribeRequest) String() string + func (m *SubscribeRequest) XXX_DiscardUnknown() + func (m *SubscribeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SubscribeRequest) XXX_Merge(src proto.Message) + func (m *SubscribeRequest) XXX_Size() int + func (m *SubscribeRequest) XXX_Unmarshal(b []byte) error + type SubscribeResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SubscribeResponse) Descriptor() ([]byte, []int) + func (*SubscribeResponse) ProtoMessage() + func (m *SubscribeResponse) Reset() + func (m *SubscribeResponse) String() string + func (m *SubscribeResponse) XXX_DiscardUnknown() + func (m *SubscribeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SubscribeResponse) XXX_Merge(src proto.Message) + func (m *SubscribeResponse) XXX_Size() int + func (m *SubscribeResponse) XXX_Unmarshal(b []byte) error + type UnimplementedServerServer struct + func (*UnimplementedServerServer) Handle(ctx context.Context, req *HandleRequest) (*HandleResponse, error) + func (*UnimplementedServerServer) Subscribe(ctx context.Context, req *SubscribeRequest) (*SubscribeResponse, error)
Go to main page