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
Constants ¶
View Source
const HttpRequestTimeout = 1 * time.Second
Variables ¶
This section is empty.
Functions ¶
func CopyFileIfNotExists ¶
func CopyWorkerProcessBinary ¶
func CopyWorkerProcessBinary() error
func DeleteAgent ¶
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 RegisterAsAgent ¶
func StartWorkerProcess ¶
Types ¶
type AddAgentResponse ¶
type AddAgentResponse struct {
Id int `json:"id"`
}
type ConflictError ¶
type ConflictError struct {
}
func (*ConflictError) Error ¶
func (e *ConflictError) Error() string
Source Files
Click to show internal directories.
Click to hide internal directories.