fake_agent_utils

Documentation

Index

• Constants
• func AssignJob(organizationUrl string, agentName string, jobId int, httpClient *http.Client) error
• func CopyFileIfNotExists(absoluteSource, relativeDest string) error
• func CopyWorkerProcessBinary() error
• func DeleteAgent(organizationUrl string, agentId int, poolId int64, httpClient *http.Client) error
• func DoesFakeAgentCapabilitiesSatisfyDemands(demands []string) bool
• func FinishJob(organizationUrl string, agentName string, jobId int, httpClient *http.Client) error
• func GetEligibleJobsSortedByStartDelay(jobs []fake_platform_server.Job) []fake_platform_server.Job
• func GetPendingJobs(organizationUrl string, poolId int64, httpClient *http.Client) ([]fake_platform_server.Job, error)
• func GetPoolIdFromName(organizationUrl, poolName string, httpClient *http.Client) (int64, error)
• func RegisterAsAgent(organizationUrl string, poolId int64, agentName string, ...) (int, error)
• func StartWorkerProcess() (*os.Process, error)
• type AddAgentResponse
• type ConflictError
  • func (e *ConflictError) Error() string

Constants

const HttpRequestTimeout = 1 * time.Second

Functions

func AssignJob

func AssignJob(organizationUrl string, agentName string, jobId int, httpClient *http.Client) error

func CopyFileIfNotExists

func CopyFileIfNotExists(absoluteSource, relativeDest string) error

func CopyWorkerProcessBinary

func CopyWorkerProcessBinary() error

func DeleteAgent

func DeleteAgent(organizationUrl string, agentId int, poolId int64, httpClient *http.Client) error

func DoesFakeAgentCapabilitiesSatisfyDemands

func DoesFakeAgentCapabilitiesSatisfyDemands(demands []string) bool

func FinishJob

func FinishJob(organizationUrl string, agentName string, jobId int, httpClient *http.Client) error

func GetEligibleJobsSortedByStartDelay

func GetEligibleJobsSortedByStartDelay(jobs []fake_platform_server.Job) []fake_platform_server.Job

func GetPendingJobs

func GetPendingJobs(organizationUrl string, poolId int64, httpClient *http.Client) ([]fake_platform_server.Job, error)

GetPendingJobs returns all pending or in-progress jobs for the given pool ID

func GetPoolIdFromName

func GetPoolIdFromName(organizationUrl, poolName string, httpClient *http.Client) (int64, error)

func RegisterAsAgent

func RegisterAsAgent(organizationUrl string, poolId int64, agentName string, httpClient *http.Client) (int, error)

func StartWorkerProcess

func StartWorkerProcess() (*os.Process, error)

Types

type AddAgentResponse

type AddAgentResponse struct {
	Id int `json:"id"`
}

type ConflictError

type ConflictError struct {
}

func (*ConflictError) Error

func (e *ConflictError) Error() string