jobs

Documentation

Index

• Variables
• func Add(agentID uuid.UUID, jobType string, jobArgs []string) (string, error)
• func AddJobChannel(agentID uuid.UUID, job *merlinJob.Job, jobArgs []string) (results string, err error)
• func Clear(agentID uuid.UUID) error
• func ClearCreated() error
• func Get(agentID uuid.UUID) ([]merlinJob.Job, error)
• func GetTableActive(agentID uuid.UUID) ([][]string, error)
• func GetTableAll() [][]string
• func Handler(m messages.Base) (messages.Base, error)
• func Idle(agentID uuid.UUID) (messages.Base, error)

Variables

var Jobs = make(map[string]info)

Jobs is a map that contains specific information about an individual job and is embedded in the JobsChannel

var JobsChannel = make(map[uuid.UUID]chan merlinJob.Job)

JobsChannel contains a map of all instantiated jobs created on the server by each Agent's ID

Functions

func Add

func Add(agentID uuid.UUID, jobType string, jobArgs []string) (string, error)

Add creates a job and adds it to the specified agent's job channel

func AddJobChannel

func AddJobChannel(agentID uuid.UUID, job *merlinJob.Job, jobArgs []string) (results string, err error)

AddJobChannel adds an already built Agent Job to the agent's job channel to be sent to the agent when it checks in. A server-side job tracking structure is also added to track job status

func Clear

func Clear(agentID uuid.UUID) error

Clear removes any jobs the queue that have been created, but NOT sent to the agent

func ClearCreated

func ClearCreated() error

ClearCreated removes all unsent jobs across all agents

func Get

func Get(agentID uuid.UUID) ([]merlinJob.Job, error)

Get returns a list of jobs that need to be sent to the agent

func GetTableActive

func GetTableActive(agentID uuid.UUID) ([][]string, error)

GetTableActive returns a list of rows that contain information about active jobs

func GetTableAll

func GetTableAll() [][]string

GetTableAll returns all unsent jobs to be displayed as a table

func Handler

func Handler(m messages.Base) (messages.Base, error)

Handler evaluates a message sent in by the agent and the subsequently executes any corresponding tasks

func Idle

func Idle(agentID uuid.UUID) (messages.Base, error)

Idle handles input idle messages from the agent and checks to see if there are any jobs to return