cloud

Documentation

Index

• Constants
• Variables
• func InitCloud(autoDiscovery bool) error
• func IsAllCloudsBusyErr(errs error) bool
• func RegistryCloudProvider(ct api.CloudType, ncf newCloudFunc) error
• type ErrCloudProvision
  • func NewErrCloudProvision() *ErrCloudProvision
  • func (cpe *ErrCloudProvision) Add(name string, err error)
  • func (cpe *ErrCloudProvision) Err() error
  • func (cpe *ErrCloudProvision) Error() string
• type Provider
  • func NewCloudProvider(c *api.Cloud) (Provider, error)

Constants

const (
	DefaultCloudPingTimeout = time.Duration(5 * time.Second)

	WorkerTimeout = time.Duration(2 * time.Hour)

	DefaultCloudName = "_inCluster"
)

Variables

var DefaultNamespace = "default"

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 InitCloud

func InitCloud(autoDiscovery bool) error

func IsAllCloudsBusyErr

func IsAllCloudsBusyErr(errs error) bool

IsAllCloudsBusyErr check whether all cloud is too busy to provision a worker

func RegistryCloudProvider

func RegistryCloudProvider(ct api.CloudType, ncf newCloudFunc) error

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)
}

func NewCloudProvider

func NewCloudProvider(c *api.Cloud) (Provider, error)