Documentation
¶
Index ¶
Constants ¶
View Source
const ( DefaultCloudPingTimeout = time.Duration(5 * time.Second) WorkerTimeout = time.Duration(2 * time.Hour) DefaultCloudName = "_inCluster" // RegistryCertPath is the path of docker registry cert file // that used for cyclone worker to pull images. // // Cyclone server will read the cert contents from RegistryCertPath, // and set it to the Env whose key is ENV_CERT_DATA in cyclone worker. RegistryCertPath string = "/tmp/certs/registry.crt" // ENV_CERT_DATA is a environment name of cert path // that used for cyclone worker to pull images. ENV_CERT_DATA string = "CERT_DATA" )
Variables ¶
View Source
var DefaultNamespace = "default"
View Source
var ( // ErrNoEnoughResource occurs when clouds have no enough resource to provison as worker ErrNoEnoughResource = errors.New("worker required resources are out of quota limit") )
Functions ¶
func IsAllCloudsBusyErr ¶
IsAllCloudsBusyErr check whether all cloud is too busy to provision a worker
func RegistryCloudProvider ¶
Types ¶
type ErrCloudProvision ¶
type ErrCloudProvision struct {
// contains filtered or unexported fields
}
ErrCloudProvision contains all clouds provision errors
func NewErrCloudProvision ¶
func NewErrCloudProvision() *ErrCloudProvision
NewErrCloudProvision return a new CloudProvisionErr
func (*ErrCloudProvision) Add ¶
func (cpe *ErrCloudProvision) Add(name string, err error)
Add adds an error to CloudProvisionErr
func (*ErrCloudProvision) Err ¶
func (cpe *ErrCloudProvision) Err() error
Err returns nil if CloudProvisionErr contains 0 error
func (*ErrCloudProvision) Error ¶
func (cpe *ErrCloudProvision) Error() string
type Provider ¶
type Provider interface {
CanProvision(quota options.Quota) (bool, error)
Resource() (*options.Resource, error)
Provision(info *api.WorkerInfo, opts *options.WorkerOptions) (*api.WorkerInfo, error)
TerminateWorker(string) error
Ping() error
ListWorkers() ([]api.WorkerInstance, error)
}
Click to show internal directories.
Click to hide internal directories.