messagequeue

Documentation

Index

• func GetMessageQueue()
• func InitMessageQueue()
• func ProcessAllMessageQueueItems()
• func ProcessMessageQueueItem(messageItem *MessageQueueItem) error
• func ShutdownMessageQueue() error
• type HttpRequestBody_MessageItem
• type MessageQueueItem

Functions

func GetMessageQueue

func GetMessageQueue()

func InitMessageQueue

func InitMessageQueue()

func ProcessAllMessageQueueItems

func ProcessAllMessageQueueItems()

func ProcessMessageQueueItem

func ProcessMessageQueueItem(messageItem *MessageQueueItem) error

func ShutdownMessageQueue

func ShutdownMessageQueue() error

Types

type HttpRequestBody_MessageItem

type HttpRequestBody_MessageItem struct {
	Item MessageQueueItem `json:"item"`
}

type MessageQueueItem

type MessageQueueItem struct {
	ID        string      `json:"_id"`
	Action    string      `json:"action"`
	Data      interface{} `json:"data"`
	Completed bool        `json:"completed"`
	Error     string      `json:"error"`
	Retries   int         `json:"retries"`
	Created   time.Time   `json:"created"`
}