package
2.2.0+incompatible
Repository: https://github.com/ccsnake/maestro.git
Documentation: pkg.go.dev
# Functions
No description provided by the author
func CreateNewBatchTask(childtasks []*MaestroTask, masterid string, src string) (ret *MaestroTask, err error) {.
No description provided by the author
Enqueu's the task into disk storage.
enques a Batch of Tasks.
No description provided by the author
No description provided by the author
No description provided by the author
When a TaskHandler has finished a step of a task, the handler should call this.
marks the current Step as Executing Used if a Task starts a new goroutine, or defers an operation This is automatically cleared by IterateTask.
No description provided by the author
No description provided by the author
No description provided by the author
LoadFromStorage Loads all tasks which were queued into storage to be called on startup.
No description provided by the author
Informs the TaskManager that a request ACK for specific Task failed to send or be recieved by the original caller of the Task This is typically a remote server.
Informs the TaskManager that a request ACK for specific Task was successful sent and recieved by the original caller of the Task This is typically a remote server.
Ensures the Task can be run by the TaskManager No error is good.
# Constants
No description provided by the author
No description provided by the author
No description provided by the author
# Structs
No description provided by the author
# Interfaces
An AckHandler is another module which can Ack a particular Task When you EnqueTask you must provide a AckHandler for the task.
A TaskHandler is another module which can handle a certain type of Task Examples are: imageManager.go and jobManager.go.