Documentation ¶
Overview ¶
Package broker is a generated protocol buffer package.
It is generated from these files:
message.proto
It has these top-level messages:
Empty PublishRequest SubscribeRequest Message
Package broker is a generated protocol buffer package.
It is generated from these files:
message.proto
It has these top-level messages:
Empty PublishRequest SubscribeRequest Message
Index ¶
- func RegisterBrokerHandler(s server.Server, hdlr BrokerHandler, opts ...server.HandlerOption)
- type Broker
- type BrokerClient
- type BrokerHandler
- type Broker_SubscribeClient
- type Broker_SubscribeStream
- type Empty
- type Message
- type PublishRequest
- type SubscribeRequest
- func (*SubscribeRequest) Descriptor() ([]byte, []int)
- func (m *SubscribeRequest) GetQueue() string
- func (m *SubscribeRequest) GetTopic() string
- func (*SubscribeRequest) ProtoMessage()
- func (m *SubscribeRequest) Reset()
- func (m *SubscribeRequest) String() string
- func (this *SubscribeRequest) Validate() error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterBrokerHandler ¶
func RegisterBrokerHandler(s server.Server, hdlr BrokerHandler, opts ...server.HandlerOption)
Types ¶
type BrokerClient ¶
type BrokerClient interface { Publish(ctx context.Context, in *PublishRequest, opts ...client.CallOption) (*Empty, error) Subscribe(ctx context.Context, in *SubscribeRequest, opts ...client.CallOption) (Broker_SubscribeClient, error) }
func NewBrokerClient ¶
func NewBrokerClient(serviceName string, c client.Client) BrokerClient
type BrokerHandler ¶
type BrokerHandler interface { Publish(context.Context, *PublishRequest, *Empty) error Subscribe(context.Context, *SubscribeRequest, Broker_SubscribeStream) error }
type Broker_SubscribeClient ¶
type Broker_SubscribeStream ¶
type Empty ¶
type Empty struct { }
func (*Empty) Descriptor ¶
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
type Message ¶
type Message struct { Header map[string]string `` /* 132-byte string literal not displayed */ Body []byte `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"` }
func (*Message) Descriptor ¶
func (*Message) ProtoMessage ¶
func (*Message) ProtoMessage()
type PublishRequest ¶
type PublishRequest struct { Topic string `protobuf:"bytes,1,opt,name=topic" json:"topic,omitempty"` Message *Message `protobuf:"bytes,2,opt,name=message" json:"message,omitempty"` }
func (*PublishRequest) Descriptor ¶
func (*PublishRequest) Descriptor() ([]byte, []int)
func (*PublishRequest) GetMessage ¶
func (m *PublishRequest) GetMessage() *Message
func (*PublishRequest) GetTopic ¶
func (m *PublishRequest) GetTopic() string
func (*PublishRequest) ProtoMessage ¶
func (*PublishRequest) ProtoMessage()
func (*PublishRequest) Reset ¶
func (m *PublishRequest) Reset()
func (*PublishRequest) String ¶
func (m *PublishRequest) String() string
func (*PublishRequest) Validate ¶
func (this *PublishRequest) Validate() error
type SubscribeRequest ¶
type SubscribeRequest struct { Topic string `protobuf:"bytes,1,opt,name=topic" json:"topic,omitempty"` Queue string `protobuf:"bytes,2,opt,name=queue" json:"queue,omitempty"` }
func (*SubscribeRequest) Descriptor ¶
func (*SubscribeRequest) Descriptor() ([]byte, []int)
func (*SubscribeRequest) GetQueue ¶
func (m *SubscribeRequest) GetQueue() string
func (*SubscribeRequest) GetTopic ¶
func (m *SubscribeRequest) GetTopic() string
func (*SubscribeRequest) ProtoMessage ¶
func (*SubscribeRequest) ProtoMessage()
func (*SubscribeRequest) Reset ¶
func (m *SubscribeRequest) Reset()
func (*SubscribeRequest) String ¶
func (m *SubscribeRequest) String() string
func (*SubscribeRequest) Validate ¶
func (this *SubscribeRequest) Validate() error
Click to show internal directories.
Click to hide internal directories.