Documentation ¶
Index ¶
- type HandlerFunc
- type Message
- func (m *Message) Ack() bool
- func (m *Message) Context() context.Context
- func (m *Message) Copy() *Message
- func (m *Message) Equals(toCompare *Message) bool
- func (m *Message) Nack() bool
- func (m *Message) SetContext(ctx context.Context) *Message
- func (m *Message) State() State
- func (m *Message) StateChange() <-chan State
- func (m *Message) WithMetadata(key, value string) *Message
- type Metadata
- type Payload
- type State
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type HandlerFunc ¶
type Message ¶
type Message struct { ID string `json:"id"` Metadata Metadata `json:"metadata"` Payload Payload `json:"payload"` // contains filtered or unexported fields }
func (*Message) StateChange ¶
func (*Message) WithMetadata ¶
Click to show internal directories.
Click to hide internal directories.