cloud

package

Go to main page

Versions in this module

v0

v0.5.0

Jun 1, 2018

Changes in this version

+ const CallbackURL

+ const RequestCPU

+ const RequestMemory

+ var DefaultRequestCPU = MustParseCPU(0.5)

+ var DefaultRequestMemory = NewBinaryQuantity(500 * 1024 * 1024)

type Cloud

+ Docker *CloudDocker

+ ID string

+ Insecure bool

+ Kubernetes *CloudKubernetes

+ Type CloudType

+ type CloudDocker struct

+ CertPath string

+ Host string

+ type CloudKubernetes struct

+ BearerToken string

+ Host string

+ InCluster bool

+ type CloudProvider interface

+ CanProvision func(need Quota) (bool, error)

+ GetCloud func() Cloud

+ Kind func() string

+ LoadWorker func(WorkerInfo) (Worker, error)

+ Name func() string

+ Ping func() error

+ Provision func(id string, opts WorkerOptions) (Worker, error)

+ Resource func() (*Resource, error)

+ type CloudType string

+ const CloudTypeDocker

+ const CloudTypeKubernetes

type DockerCloud

+ func (cloud *DockerCloud) GetCloud() Cloud

type K8SCloud

+ func (cloud *K8SCloud) GetCloud() Cloud

type WorkerOptions

+ MountPath string

v0.4.0

Jan 26, 2018

v0.3.5

May 7, 2018

v0.3.5-hr

May 9, 2018

v0.3.4

Mar 4, 2018

Changes in this version

type WorkerOptions

+ BuildTool string

+ CacheVolume string

v0.3.3

Jan 4, 2018

v0.3.1

Dec 20, 2017

v0.3.0

Dec 1, 2017

Changes in this version

type WorkerInfo

+ Namespace string

type WorkerOptions

+ Namespace string

v0.2.0

Oct 13, 2017

Changes in this version

+ const ClairDisable

+ const ClairServer

+ const ConsoleWebEndpoint

+ const CycloneServer

+ const GithubClient

+ const GithubSecret

+ const GitlabClient

+ const GitlabSecret

+ const GitlabURL

+ const KindDockerCloud

+ const KindK8SCloud

+ const LimitCPU

+ const LimitMemory

+ const LogServer

+ const RegistryLocation

+ const RegistryPassword

+ const RegistryUsername

+ const ResourceCPU

+ const ResourceLimitsCPU

+ const ResourceLimitsMemory

+ const ResourceMemory

+ const ResourceRequestsCPU

+ const ResourceRequestsMemory

+ const WorkerEventID

+ const WorkerImage

+ const WorkerTimeout

+ const WorkingDir

+ var CloudFactory = register.NewRegister()

+ var Debug = false

+ var DefaultCloudPingTimeout = time.Duration(5 * time.Second)

+ var DefaultLimitCPU = MustParseCPU(0.5)

+ var DefaultLimitMemory = NewBinaryQuantity(500 * 1024 * 1024)

+ var DefaultQuota = Quota

+ var ErrNoEnoughResource = errors.New("worker required resources are out of quota limit")

+ var ZeroQuantity = NewDecimalQuantity(0)

+ var ZeroQuota = Quota

+ func BytesSize(size float64) string

+ func CustomSize(format string, size float64, base float64, _map []string) string

+ func IsAllCloudsBusyErr(errs error) bool

+ func RegisterConstructor(kind string, cc Constructor)

+ type Cloud interface

+ CanProvision func(need Quota) (bool, error)

+ GetOptions func() Options

+ Kind func() string

+ LoadWorker func(WorkerInfo) (Worker, error)

+ Name func() string

+ Ping func() error

+ Provision func(id string, opts WorkerOptions) (Worker, error)

+ Resource func() (*Resource, error)

+ func NewDockerCloud(opts Options) (Cloud, error)

+ func NewK8SCloud(opts Options) (Cloud, error)

+ func NewK8SCloudInCluster(opts Options) (Cloud, error)

+ type Constructor func(Options) (Cloud, error)

+ func GetConstructor(kind string) Constructor

+ type Controller struct

+ Clouds map[string]Cloud

+ func NewController() *Controller

+ func (cc *Controller) AddClouds(opts ...Options) error

+ func (cc *Controller) DeleteCloud(name string)

+ func (cc *Controller) GetCloud(name string) (Cloud, bool)

+ func (cc *Controller) LoadWorker(info WorkerInfo) (Worker, error)

+ func (cc *Controller) Provision(id string, opts WorkerOptions) (Worker, error)

+ func (cc *Controller) Resources() (map[string]*Resource, error)

+ type DockerCloud struct

+ func (cloud *DockerCloud) CanProvision(need Quota) (bool, error)

+ func (cloud *DockerCloud) Client() *apiclient.Client

+ func (cloud *DockerCloud) GetOptions() Options

+ func (cloud *DockerCloud) Kind() string

+ func (cloud *DockerCloud) LoadWorker(info WorkerInfo) (Worker, error)

+ func (cloud *DockerCloud) Name() string

+ func (cloud *DockerCloud) Ping() error

+ func (cloud *DockerCloud) Provision(id string, wopts WorkerOptions) (Worker, error)

+ func (cloud *DockerCloud) Resource() (*Resource, error)

+ type DockerWorker struct

+ func (worker *DockerWorker) Do() error

+ func (worker *DockerWorker) GetWorkerInfo() WorkerInfo

+ func (worker *DockerWorker) IsTimeout() (bool, time.Duration)

+ func (worker *DockerWorker) Terminate() error

+ type ErrCloudProvision struct

+ func NewErrCloudProvision() *ErrCloudProvision

+ func (cpe *ErrCloudProvision) Add(name string, err error)

+ func (cpe *ErrCloudProvision) Err() error

+ func (cpe *ErrCloudProvision) Error() string

+ type K8SCloud struct

+ func (cloud *K8SCloud) CanProvision(quota Quota) (bool, error)

+ func (cloud *K8SCloud) Client() *kubernetes.Clientset

+ func (cloud *K8SCloud) GetOptions() Options

+ func (cloud *K8SCloud) Kind() string

+ func (cloud *K8SCloud) LoadWorker(info WorkerInfo) (Worker, error)

+ func (cloud *K8SCloud) Name() string

+ func (cloud *K8SCloud) Ping() error

+ func (cloud *K8SCloud) Provision(id string, wopts WorkerOptions) (Worker, error)

+ func (cloud *K8SCloud) Resource() (*Resource, error)

+ type K8SPodWorker struct

+ func (worker *K8SPodWorker) Do() error

+ func (worker *K8SPodWorker) GetWorkerInfo() WorkerInfo

+ func (worker *K8SPodWorker) IsTimeout() (bool, time.Duration)

+ func (worker *K8SPodWorker) Terminate() error

+ type Options struct

+ DockerCertPath string

+ Host string

+ ID string

+ Insecure bool

+ K8SBearerToken string

+ K8SInCluster bool

+ K8SNamespace string

+ Kind string

+ Name string

+ type Quantity struct

+ func MustParseCPU(value float64) *Quantity

+ func MustParseMemory(value float64) *Quantity

+ func NewBinaryQuantity(value int) *Quantity

+ func NewDecimalQuantity(value int) *Quantity

+ func NewQuantity(value int64, format resource.Format) *Quantity

+ func NewQuantityFor(q resource.Quantity) *Quantity

+ func (q *Quantity) Set(value string) error

+ func (q Quantity) DeepCopy() Quantity

+ func (q Quantity) String() string

+ type Quota map[string]*Quantity

+ func (q Quota) Add(y Quota)

+ func (q Quota) DeepCopy() Quota

+ func (q Quota) Enough(y Quota, z Quota) bool

+ func (q Quota) IsZero() bool

+ func (q Quota) SetDefault()

+ func (q Quota) Sub(y Quota)

+ func (q Quota) ToDockerQuota() container.Resources

+ func (q Quota) ToK8SQuota() apiv1.ResourceRequirements

+ type Resource struct

+ Limit Quota

+ Used Quota

+ func NewResource() *Resource

+ func (r *Resource) Add(y *Resource)

+ type Worker interface

+ Do func() error

+ GetWorkerInfo func() WorkerInfo

+ IsTimeout func() (bool, time.Duration)

+ Terminate func() error

+ type WorkerEnvs struct

+ ClairDisable bool

+ ClairServer string

+ ConsoleWebEndpoint string

+ CycloneServer string

+ GithubClient string

+ GithubSecret string

+ GitlabClient string

+ GitlabSecret string

+ GitlabURL string

+ LogServer string

+ RegistryLocation string

+ RegistryPassword string

+ RegistryUsername string

+ WorkerImage string

+ func NewWorkerEnvs() *WorkerEnvs

+ func (env *WorkerEnvs) AddFlags(app *cli.App)

+ type WorkerInfo struct

+ CloudKind string

+ CloudName string

+ ContainerID string

+ CreateTime time.Time

+ DueTime time.Time

+ Name string

+ PodName string

+ type WorkerOptions struct

+ Quota Quota

+ WorkerEnvs *WorkerEnvs

+ func NewWorkerOptions() *WorkerOptions

+ func (opts *WorkerOptions) AddFlags(app *cli.App)

+ func (opts WorkerOptions) DeepCopy() WorkerOptions

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL