fleet

Documentation

Index

• Variables
• func LazyQueueStateReconciliation()
• func NumSchedulableAgents() int
• func QueueStateReconciliation()
• func RemoveAgentByID(projectId string)
• func RequestFileDownload(fileIDs ...uuid.UUID)
• func ScheduleJobs(jobIds []string) ([]string, error)
• func Setup() error
• func StopJob(job db.Job, reason string)
• type AgentConnection
  • func RegisterAgentFromWebsocket(conn *websocket.Conn, agentId string) *AgentConnection
  • func (a *AgentConnection) Handle() error
  • func (a *AgentConnection) MarkDisconnected()
  • func (a *AgentConnection) RequestFileDelete(fileID string) error
  • func (a *AgentConnection) RequestFileDownload(fileIDs ...uuid.UUID) error

Variables

var ErrJobAlreadyScheduled = errors.New("job already scheduled to start")

var ErrJobDoesntExist = errors.New("job doesn't exist")

var ErrNoAgentsOnline = errors.New("no agents online")

Functions

func LazyQueueStateReconciliation

func LazyQueueStateReconciliation()

func NumSchedulableAgents

func NumSchedulableAgents() int

func QueueStateReconciliation

func QueueStateReconciliation()

func RemoveAgentByID

func RemoveAgentByID(projectId string)

func RequestFileDownload

func RequestFileDownload(fileIDs ...uuid.UUID)

func ScheduleJobs

func ScheduleJobs(jobIds []string) ([]string, error)

func Setup

func Setup() error

func StopJob

func StopJob(job db.Job, reason string)

Types

type AgentConnection

type AgentConnection struct {
	// contains filtered or unexported fields
}

func RegisterAgentFromWebsocket

func RegisterAgentFromWebsocket(conn *websocket.Conn, agentId string) *AgentConnection

func (*AgentConnection) Handle

func (a *AgentConnection) Handle() error

func (*AgentConnection) MarkDisconnected

func (a *AgentConnection) MarkDisconnected()

func (*AgentConnection) RequestFileDelete

func (a *AgentConnection) RequestFileDelete(fileID string) error

func (*AgentConnection) RequestFileDownload

func (a *AgentConnection) RequestFileDownload(fileIDs ...uuid.UUID) error