Documentation ¶
Overview ¶
Package broker is a generated protocol buffer package.
It is generated from these files:
message.proto
It has these top-level messages:
Message
Index ¶
- type Broker
- type Handler
- type Message
- func (m *Message) GetHeader() map[string]string
- func (m *Message) Marshal() (data []byte, err error)
- func (m *Message) MarshalTo(data []byte) (n int, err error)
- func (*Message) ProtoMessage()
- func (m *Message) Reset()
- func (m *Message) Size() (n int)
- func (m *Message) String() string
- func (m *Message) Unmarshal(data []byte) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Message ¶
type Message struct { Id string `protobuf:"bytes,1,opt,proto3" json:"Id,omitempty"` Header map[string]string `` /* 134-byte string literal not displayed */ Retry int32 `protobuf:"varint,3,opt,proto3" json:"Retry,omitempty"` Body []byte `protobuf:"bytes,4,opt,proto3" json:"Body,omitempty"` }
func (*Message) ProtoMessage ¶
func (*Message) ProtoMessage()
Click to show internal directories.
Click to hide internal directories.