task

Documentation

Index

• func GetAllTasks()
• func InitMessageQueue()
• func ProcessAllMessageQueueItems()
• func ProcessMessageQueueItem(taskItem *TaskItem) error
• func ShutdownMessageQueue() error
• type HttpRequestBody_MessageItem
• type TaskItem
• type UpdateModConfigData

Functions

func GetAllTasks

func GetAllTasks()

func InitMessageQueue

func InitMessageQueue()

func ProcessAllMessageQueueItems

func ProcessAllMessageQueueItems()

func ProcessMessageQueueItem

func ProcessMessageQueueItem(taskItem *TaskItem) error

func ShutdownMessageQueue

func ShutdownMessageQueue() error

Types

type HttpRequestBody_MessageItem

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

type TaskItem

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

type UpdateModConfigData

type UpdateModConfigData struct {
	ModReference string `json:"modReference"`
	ModConfig    string `json:"modConfig"`
}