backend

Documentation

Index

• Variables
• func GetErrorFromBackend(taskUUID string) (taskError string, err error)
• func GetResultsFromBackend(taskUUID string) (taskResults string, err error)
• func GetStateFromBackend(taskUUID string) (state int, err error)
• func GetTaskInfos() (infos []models.Task)
• func TaskRunTimeout(taskUUID string, taskCreateOn int) bool
• func UpdateState()
• func UpdateStateToDB(dataTask models.Task) error

Variables

var (
	SUCCESS  = 0
	PENDING  = 1
	RECEIVED = 2
	STARTED  = 3
	RETRY    = 4
	FAILURE  = 5
)

var BackendServer iface.Backend

var SenderServer *machinery.Server

Functions

func GetErrorFromBackend

func GetErrorFromBackend(taskUUID string) (taskError string, err error)

GetErrorFromBackend when task is FAILURE, get state of task from backend

func GetResultsFromBackend

func GetResultsFromBackend(taskUUID string) (taskResults string, err error)

GetResultsFromBackend when task is SUCCESS, get results of task from backend

func GetStateFromBackend

func GetStateFromBackend(taskUUID string) (state int, err error)

GetStateFromBackend get state of task from backend

func GetTaskInfos

func GetTaskInfos() (infos []models.Task)

GetTaskInfos get statks from DB

func TaskRunTimeout

func TaskRunTimeout(taskUUID string, taskCreateOn int) bool

TaskRunTimeout if task is send success, duration TASK_TIMEOUT, task is not FAILURE or SUCCESS.

func UpdateState

func UpdateState()

UpdateState update state of task

func UpdateStateToDB

func UpdateStateToDB(dataTask models.Task) error

UpdateStateToDB update info of task in DB