replicaset

package
v0.0.0-...-da10ef3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 6, 2016 License: Apache-2.0 Imports: 20 Imported by: 0

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 replication 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) *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.

Jump to

Keyboard shortcuts

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