messages

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 9, 2021 License: BSD-3-Clause Imports: 1 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// InformType_Started type when process started
	InformType_Started string = "Started"
	// InformType_Finished type when process finished
	InformType_Finished string = "Finished"
	// InformType_Failed type when process failed
	InformType_Failed 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 {
}

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

type Tag 

type Tag struct {
	Key   string `json:"key"`
	Value string `json:"value"`
}

Tag keeps key/value in message

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.