Versions in this module Expand all Collapse all v0 v0.4.0 Jan 27, 2017 v0.3.0 Jan 12, 2017 Changes in this version + var ErrNoWorker = fmt.Errorf("cds: no worker found") + var WorkerHeartbeatTimeout = 30.0 + func CreateBuiltinActions(db *sql.DB) error + func CreateBuiltinEnvironments(db *sql.DB) error + func DeleteUserKey(db database.Executer, key string) error + func DeleteWorker(db *sql.DB, id string) error + func DeleteWorkerModel(db gorp.SqlExecutor, ID int64) error + func DeleteWorkerModelCapability(db database.Executer, workerID int64, capaName string) error + func EstimateWorkerModelNeeds(db *sql.DB, uid int64, workerModelStatus ModelStatusFunc, ...) ([]sdk.ModelStatus, error) + func FindBuildingWorker(db database.Querier, actionBuildID string) (string, error) + func GenerateKey() (string, error) + func GenerateToken() (string, error) + func GetModelCapabilities(db database.Querier, modelID int64) ([]sdk.Requirement, error) + func Heartbeat() + func InsertToken(db *sql.DB, groupID int64, token string, e sdk.Expiration) error + func InsertUserKey(db *sql.DB, userID int64, key string, e sdk.Expiration) error + func InsertWorker(db database.Executer, w *sdk.Worker, groupID int64) error + func InsertWorkerModel(db gorp.SqlExecutor, model *sdk.Model) error + func LoadDeadWorkers(db *sql.DB, timeout float64) ([]sdk.Worker, error) + func LoadSharedWorkerModels(db gorp.SqlExecutor) ([]sdk.Model, error) + func LoadUserKey(db *sql.DB, key string) (int64, sdk.Expiration, error) + func LoadWorker(db database.Querier, id string) (*sdk.Worker, error) + func LoadWorkerModelByID(db gorp.SqlExecutor, ID int64) (*sdk.Model, error) + func LoadWorkerModelByName(db gorp.SqlExecutor, name string) (*sdk.Model, error) + func LoadWorkerModelCapabilities(db database.Querier, workerID int64) ([]sdk.Requirement, error) + func LoadWorkerModelStatusForAdminUser(db *sql.DB, userID int64) ([]sdk.ModelStatus, error) + func LoadWorkerModelStatusForGroup(db *sql.DB, groupID int64) ([]sdk.ModelStatus, error) + func LoadWorkerModels(db gorp.SqlExecutor) ([]sdk.Model, error) + func LoadWorkerModelsByGroup(db gorp.SqlExecutor, groupID int64) ([]sdk.Model, error) + func LoadWorkerModelsByUser(db gorp.SqlExecutor, userID int64) ([]sdk.Model, error) + func LoadWorkerModelsUsableOnGroup(db gorp.SqlExecutor, groupID, sharedinfraGroupID int64) ([]sdk.Model, error) + func LoadWorkers(db *sql.DB) ([]sdk.Worker, error) + func LoadWorkersByModel(db database.Querier, modelID int64) ([]sdk.Worker, error) + func ModelCapabilititiesCacheLoader(delay time.Duration) + func RefreshWorker(db *sql.DB, workerID string) error + func RegisterWorker(db *sql.DB, name string, key string, modelID int64, h *sdk.Hatchery, ...) (*sdk.Worker, error) + func SetStatus(db database.Executer, workerID string, status sdk.Status) error + func SetToBuilding(db database.Executer, workerID string, actionBuildID int64) error + func UpdateWorkerModel(db gorp.SqlExecutor, model sdk.Model) error + func UpdateWorkerModelCapability(db database.Executer, capa sdk.Requirement, modelID int64) error + func UpdateWorkerStatus(db database.Executer, workerID string, status sdk.Status) error + type ActionBuildInfo struct + Action sdk.Action + ActionBuild sdk.ActionBuild + Secrets []sdk.Variable + type ActionCount struct + Action sdk.Action + Count int64 + func LoadAllActionCount(db *sql.DB, userID int64) ([]ActionCount, error) + func LoadGroupActionCount(db *sql.DB, groupID int64) ([]ActionCount, error) + type ActionCountFunc func(*sql.DB, int64) ([]ActionCount, error) + type ModelStatusFunc func(*sql.DB, int64) ([]sdk.ModelStatus, error) + type RegistrationForm struct + BinaryCapabilities []string + Hatchery int64 + Model int64 + Name string + UserKey string + type Token struct + Created time.Time + Expiration sdk.Expiration + GroupID int64 + Token string + func LoadToken(db *sql.DB, token string) (Token, error)