Versions in this module Expand all Collapse all v1 v1.0.1 May 10, 2021 v1.0.0 May 9, 2021 Changes in this version + func RegisterBrokerHandler(s server.Server, hdlr BrokerHandler, opts ...server.HandlerOption) error + type BrokerHandler interface + Publish func(context.Context, *PublishRequest, *Empty) error + Subscribe func(context.Context, *SubscribeRequest, Broker_SubscribeStream) error + type BrokerService interface + Publish func(ctx context.Context, in *PublishRequest, opts ...client.CallOption) (*Empty, error) + Subscribe func(ctx context.Context, in *SubscribeRequest, opts ...client.CallOption) (Broker_SubscribeService, error) + func NewBrokerService(name string, c client.Client) BrokerService + type Broker_SubscribeService interface + Close func() error + Recv func() (*Message, error) + RecvMsg func(interface{}) error + SendMsg func(interface{}) error + type Broker_SubscribeStream interface + Close func() error + RecvMsg func(interface{}) error + Send func(*Message) error + SendMsg func(interface{}) error + type Empty struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Empty) Descriptor() ([]byte, []int) + func (*Empty) ProtoMessage() + func (m *Empty) Reset() + func (m *Empty) String() string + func (m *Empty) XXX_DiscardUnknown() + func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Empty) XXX_Merge(src proto.Message) + func (m *Empty) XXX_Size() int + func (m *Empty) XXX_Unmarshal(b []byte) error + type Message struct + Body []byte + Header map[string]string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Message) Descriptor() ([]byte, []int) + func (*Message) ProtoMessage() + func (m *Message) GetBody() []byte + func (m *Message) GetHeader() map[string]string + func (m *Message) Reset() + func (m *Message) String() string + func (m *Message) XXX_DiscardUnknown() + func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Message) XXX_Merge(src proto.Message) + func (m *Message) XXX_Size() int + func (m *Message) XXX_Unmarshal(b []byte) error + type PublishRequest struct + Message *Message + Topic string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PublishRequest) Descriptor() ([]byte, []int) + func (*PublishRequest) ProtoMessage() + func (m *PublishRequest) GetMessage() *Message + func (m *PublishRequest) GetTopic() string + func (m *PublishRequest) Reset() + func (m *PublishRequest) String() string + func (m *PublishRequest) XXX_DiscardUnknown() + func (m *PublishRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PublishRequest) XXX_Merge(src proto.Message) + func (m *PublishRequest) XXX_Size() int + func (m *PublishRequest) XXX_Unmarshal(b []byte) error + type SubscribeRequest struct + Queue string + Topic string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SubscribeRequest) Descriptor() ([]byte, []int) + func (*SubscribeRequest) ProtoMessage() + func (m *SubscribeRequest) GetQueue() string + 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 Incompatible versions in this module v2.3.0+incompatible May 9, 2021
Go to main page