Documentation
¶
Index ¶
Constants ¶
View Source
const ( // InformTypeStarted type when process started InformTypeStarted string = "Started" // InformTypeFinished type when process finished InformTypeFinished string = "Finished" // InformTypeFailed type when process failed InformTypeFailed string = "Failed" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type InformMessage ¶
type InformMessage struct {
QueueMessage
Type string `json:"type"`
At time.Time `json:"at"`
}
InformMessage message with inform information
type Message ¶
type Message interface {
GetID() string
}
Message base message interface for sending to queue
type QueueMessage ¶
type QueueMessage struct {
ID string `json:"id"`
Tags []Tag `json:"tags,omitempty"`
Error string `json:"error,omitempty"`
}
QueueMessage message going throuht broker
func NewQueueMessageFromM ¶
func NewQueueMessageFromM(m *QueueMessage) *QueueMessage
NewQueueMessageFromM copies message
func (*QueueMessage) GetID ¶ added in v1.2.68
func (m *QueueMessage) GetID() string
GetID returm message's ID
Source Files
Click to show internal directories.
Click to hide internal directories.