Versions in this module Expand all Collapse all v2 v2.9.3 Mar 19, 2021 Changes in this version + func NewBrokerEndpoints() []*api.Endpoint + func RegisterBrokerHandler(s server.Server, hdlr BrokerHandler, opts ...server.HandlerOption) error + func RegisterBrokerServer(s *grpc.Server, srv BrokerServer) + type BrokerClient interface + Publish func(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*Empty, error) + Subscribe func(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (Broker_SubscribeClient, error) + func NewBrokerClient(cc *grpc.ClientConn) BrokerClient + type BrokerHandler interface + Publish func(context.Context, *PublishRequest, *Empty) error + Subscribe func(context.Context, *SubscribeRequest, Broker_SubscribeStream) error + type BrokerServer interface + Publish func(context.Context, *PublishRequest) (*Empty, error) + Subscribe func(*SubscribeRequest, Broker_SubscribeServer) 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_SubscribeClient interface + Recv func() (*Message, error) + type Broker_SubscribeServer interface + Send func(*Message) error + type Broker_SubscribeService interface + Close func() error + Context func() context.Context + Recv func() (*Message, error) + RecvMsg func(interface{}) error + SendMsg func(interface{}) error + type Broker_SubscribeStream interface + Close func() error + Context func() context.Context + 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 + type UnimplementedBrokerServer struct + func (*UnimplementedBrokerServer) Publish(ctx context.Context, req *PublishRequest) (*Empty, error) + func (*UnimplementedBrokerServer) Subscribe(req *SubscribeRequest, srv Broker_SubscribeServer) error