instancegroup

Documentation

Index

• Constants
• func GetCondition(status cluster.InstanceGroupStatus, ...) *cluster.InstanceGroupCondition
• func NewInstanceGroupCondition(condType cluster.InstanceGroupConditionType, status api.ConditionStatus, ...) cluster.InstanceGroupCondition
• func RemoveCondition(status *cluster.InstanceGroupStatus, ...)
• func SetCondition(status *cluster.InstanceGroupStatus, condition cluster.InstanceGroupCondition)
• type InstanceGroupController
  • func NewInstanceGroupController(kubeClient clientset.Interface, namespace string, burstReplicas int, ...) *InstanceGroupController
  • func (rsc *InstanceGroupController) Run(workers int, stopCh <-chan struct{})
  • func (rsc *InstanceGroupController) SetEventRecorder(recorder record.EventRecorder)

Constants

const (
	// We'll attempt to recompute the required replicas of all InstanceGroups
	// that have fulfilled their expectations at least this often. This recomputation
	// happens based on contents in local instance storage.
	FullControllerResyncPeriod = 30 * time.Second

	// Realistic value of the burstReplica field for the replica set manager based off
	// performance requirements for kubernetes 1.0.
	// TODO: adjust for instancegroups
	BurstReplicas = 500
)

Functions

func GetCondition

func GetCondition(status cluster.InstanceGroupStatus, condType cluster.InstanceGroupConditionType) *cluster.InstanceGroupCondition

GetCondition returns a replica set condition with the provided type if it exists.

func NewInstanceGroupCondition

func NewInstanceGroupCondition(condType cluster.InstanceGroupConditionType, status api.ConditionStatus, reason, msg string) cluster.InstanceGroupCondition

NewInstanceGroupCondition creates a new replica set condition.

func RemoveCondition

func RemoveCondition(status *cluster.InstanceGroupStatus, condType cluster.InstanceGroupConditionType)

RemoveCondition removes the condition with the provided type from the replica set status.

func SetCondition

func SetCondition(status *cluster.InstanceGroupStatus, condition cluster.InstanceGroupCondition)

SetCondition adds/replaces the given condition in the replica set status. If the condition that we are about to add already exists and has the same status and reason then we are not going to update.

Types

type InstanceGroupController

type InstanceGroupController struct {
	// contains filtered or unexported fields
}

InstanceGroupController is responsible for synchronizing InstanceGroup objects stored in the system with actual running Instances.

func NewInstanceGroupController

func NewInstanceGroupController(kubeClient clientset.Interface, namespace string, burstReplicas int, lookupCacheSize int, garbageCollectorEnabled bool) *InstanceGroupController

NewInstanceGroupController configures a replica set controller with the specified event recorder

func (*InstanceGroupController) Run

func (rsc *InstanceGroupController) Run(workers int, stopCh <-chan struct{})

Run begins watching and syncing.

func (*InstanceGroupController) SetEventRecorder

func (rsc *InstanceGroupController) SetEventRecorder(recorder record.EventRecorder)

SetEventRecorder replaces the event recorder used by the InstanceGroupController with the given recorder. Only used for testing.