Documentation
¶
Index ¶
- type Handler
- type Message
- func (m *Message) GetCreateAt() time.Time
- func (m *Message) GetDelay() time.Duration
- func (m *Message) GetHeaders() map[string]string
- func (m *Message) GetID() string
- func (m *Message) GetPayload() []byte
- func (m *Message) GetRetry() int
- func (m *Message) GetTopic() string
- func (m *Message) SetCreateAt(createAt time.Time) *Message
- func (m *Message) SetDelay(delay time.Duration) *Message
- func (m *Message) SetHeaders(headers map[string]string) *Message
- func (m *Message) SetID(id string) *Message
- func (m *Message) SetRetry(retry int) *Message
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Message ¶
type Message struct {
ID string `json:"id"`
Topic string `json:"topic"`
Payload []byte `json:"payload"`
Headers map[string]string `json:"headers"`
Delay time.Duration `json:"delay,omitempty"`
Retry int `json:"retry,omitempty"`
CreateAt time.Time `json:"create_at"`
}
Message 消息结构
func (*Message) GetCreateAt ¶ added in v0.3.4
func (*Message) GetHeaders ¶ added in v0.3.4
func (*Message) GetPayload ¶ added in v0.3.4
func (*Message) SetCreateAt ¶ added in v0.3.4
func (*Message) SetHeaders ¶ added in v0.3.4
Source Files
Click to show internal directories.
Click to hide internal directories.