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
Click to show internal directories.
Click to hide internal directories.