package replicaset

import "k8s.io/kubernetes/pkg/controller/replicaset"

Package replicaset contains logic for watching and synchronizing ReplicaSets.

Index ¶

• Constants
• type ReplicaSetController
• func NewReplicaSetController(podInformer cache.SharedIndexInformer, kubeClient clientset.Interface, resyncPeriod controller.ResyncPeriodFunc, burstReplicas int, lookupCacheSize int, garbageCollectorEnabled bool) *ReplicaSetController
• func NewReplicaSetControllerFromClient(kubeClient clientset.Interface, resyncPeriod controller.ResyncPeriodFunc, burstReplicas int, lookupCacheSize int) *ReplicaSetController
• func (rsc *ReplicaSetController) Run(workers int, stopCh <-chan struct{})
• func (rsc *ReplicaSetController) SetEventRecorder(recorder record.EventRecorder)

Constants ¶

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

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

	// We must avoid counting pods until the pod store has synced. If it hasn't synced, to
	// avoid a hot loop, we'll wait this long between checks.
	PodStoreSyncedPollPeriod = 100 * time.Millisecond
)

Types ¶

type ReplicaSetController ¶

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

ReplicaSetController is responsible for synchronizing ReplicaSet objects stored in the system with actual running pods.

func NewReplicaSetController ¶

func NewReplicaSetController(podInformer cache.SharedIndexInformer, kubeClient clientset.Interface, resyncPeriod controller.ResyncPeriodFunc, burstReplicas int, lookupCacheSize int, garbageCollectorEnabled bool) *ReplicaSetController

NewReplicaSetController creates a new ReplicaSetController.

func NewReplicaSetControllerFromClient ¶

func NewReplicaSetControllerFromClient(kubeClient clientset.Interface, resyncPeriod controller.ResyncPeriodFunc, burstReplicas int, lookupCacheSize int) *ReplicaSetController

NewReplicationManagerFromClient creates a new ReplicationManager that runs its own informer.

func (*ReplicaSetController) Run ¶

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

Run begins watching and syncing.

func (*ReplicaSetController) SetEventRecorder ¶

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

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

Source Files ¶

doc.go replica_set.go replica_set_utils.go

Directories ¶