controller

Apr 12, 2017

Changes in this version

type InstanceControlInterface

+ BindReservedInstance func(ri *cluster.ReservedInstance, instance *cluster.Instance, unbind bool) (updatedRI *cluster.ReservedInstance, err error)

+ UnbindInstanceWithReservedInstance func(instance *cluster.Instance) error

type RealInstanceControl

+ func (r RealInstanceControl) BindReservedInstance(ri *cluster.ReservedInstance, instance *cluster.Instance, unbind bool) (updatedRI *cluster.ReservedInstance, err error)

+ func (r RealInstanceControl) UnbindInstanceWithReservedInstance(instance *cluster.Instance) (err error)

Mar 17, 2017

Changes in this version

+ var CSRToken = cluster.AnnotationPrefix + "csr"

Mar 8, 2017

Changes in this version

+ const FailedCreateInstanceReason

+ const FailedDeleteInstanceReason

+ const SuccessfulCreateInstanceReason

+ const SuccessfulDeleteInstanceReason

+ func FilterActiveInstances(instances []*cluster.Instance) []*cluster.Instance

+ func GetInstanceFromTemplate(template *cluster.InstanceTemplateSpec, parentObject runtime.Object, ...) (*cluster.Instance, error)

+ func GetSecretsFromTemplate(template *cluster.InstanceTemplateSpec, parentObject runtime.Object, ...) ([]*api.Secret, error)

+ func InstanceKey(instance *cluster.Instance) string

+ func IsInstanceActive(p *cluster.Instance) bool

+ type ActiveInstances []*cluster.Instance

+ func (s ActiveInstances) Len() int

+ func (s ActiveInstances) Less(i, j int) bool

+ func (s ActiveInstances) Swap(i, j int)

+ type InstanceControlInterface interface

+ CreateInstances func(namespace string, template *cluster.InstanceTemplateSpec, ...) error

+ CreateInstancesOnNode func(nodeName, namespace string, template *cluster.InstanceTemplateSpec, ...) error

+ CreateInstancesWithControllerRef func(namespace string, template *cluster.InstanceTemplateSpec, ...) error

+ DeleteInstance func(namespace string, instanceID string, object runtime.Object) error

+ PatchInstance func(namespace, name string, data []byte) error

+ type InstanceControllerRefManager struct

+ func NewInstanceControllerRefManager(instanceControl InstanceControlInterface, controllerObject api.ObjectMeta, ...) *InstanceControllerRefManager

+ func (m *InstanceControllerRefManager) AdoptInstance(instance *cluster.Instance) error

+ func (m *InstanceControllerRefManager) Classify(instances []*cluster.Instance) (matchesAndControlled []*cluster.Instance, ...)

+ func (m *InstanceControllerRefManager) ReleaseInstance(instance *cluster.Instance) error

+ type RealInstanceControl struct

+ KubeClient clientset.Interface

+ Recorder record.EventRecorder

+ func (r RealInstanceControl) CreateInstances(namespace string, template *cluster.InstanceTemplateSpec, ...) error

+ func (r RealInstanceControl) CreateInstancesOnNode(nodeName, namespace string, template *cluster.InstanceTemplateSpec, ...) error

+ func (r RealInstanceControl) CreateInstancesWithControllerRef(namespace string, template *cluster.InstanceTemplateSpec, ...) error

+ func (r RealInstanceControl) DeleteInstance(namespace string, instanceID string, object runtime.Object) error

+ func (r RealInstanceControl) PatchInstance(namespace, name string, data []byte) error