Documentation
¶
Overview ¶
Package replicaset contains logic for watching and synchronizing ReplicaSets.
Index ¶
Constants ¶
View Source
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
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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(kubeClient clientset.Interface, resyncPeriod controller.ResyncPeriodFunc, burstReplicas int, lookupCacheSize int) *ReplicaSetController
NewReplicaSetController creates a new ReplicaSetController.
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.
Click to show internal directories.
Click to hide internal directories.