resource

Documentation

Index

• Constants
• type Queue
  • func NewResourceQueue() Queue
  • func (q *Queue) AddTask(rpc common.RPCCall, rj *common.Job) error
  • func (q *Queue) AddTool(tooler common.Tooler)
  • func (q *Queue) AllTaskStatus(rpc common.RPCCall, j *[]common.Job) error
  • func (q *Queue) Ping(ping int, pong *int) error
  • func (q *Queue) ResourceHardware(rpc common.RPCCall, hw *map[string]bool) error
  • func (q *Queue) ResourceTools(rpc common.RPCCall, tools *[]common.Tool) error
  • func (q *Queue) TaskPause(rpc common.RPCCall, j *common.Job) error
  • func (q *Queue) TaskQuit(rpc common.RPCCall, j *common.Job) error
  • func (q *Queue) TaskRun(rpc common.RPCCall, j *common.Job) error
  • func (q *Queue) TaskStatus(rpc common.RPCCall, j *common.Job) error

Constants

const (
	ERROR_AUTH    = "Call to resource did not have the proper authentication token."
	ERROR_NO_TOOL = "Tool specified does not exit."
)

Types

type Queue

type Queue struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewResourceQueue

func NewResourceQueue() Queue

func (*Queue) AddTask

func (q *Queue) AddTask(rpc common.RPCCall, rj *common.Job) error

func (*Queue) AddTool

func (q *Queue) AddTool(tooler common.Tooler)

func (*Queue) AllTaskStatus

func (q *Queue) AllTaskStatus(rpc common.RPCCall, j *[]common.Job) error

func (*Queue) Ping

func (q *Queue) Ping(ping int, pong *int) error

Task RPC functions

func (*Queue) ResourceHardware

func (q *Queue) ResourceHardware(rpc common.RPCCall, hw *map[string]bool) error

func (*Queue) ResourceTools

func (q *Queue) ResourceTools(rpc common.RPCCall, tools *[]common.Tool) error

func (*Queue) TaskPause

func (q *Queue) TaskPause(rpc common.RPCCall, j *common.Job) error

func (*Queue) TaskQuit

func (q *Queue) TaskQuit(rpc common.RPCCall, j *common.Job) error

func (*Queue) TaskRun

func (q *Queue) TaskRun(rpc common.RPCCall, j *common.Job) error

func (*Queue) TaskStatus

func (q *Queue) TaskStatus(rpc common.RPCCall, j *common.Job) error