Versions in this module Expand all Collapse all v1 v1.18.1 Apr 6, 2022 Changes in this version + func RegisterServerHandler(s server.Server, hdlr ServerHandler, opts ...server.HandlerOption) error + 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 ServerHandler 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
Go to main page