package replication

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

Package replication contains logic for watching and synchronizing replication controllers.

Index ¶

• Constants
• func GetCondition(status v1.ReplicationControllerStatus, condType v1.ReplicationControllerConditionType) *v1.ReplicationControllerCondition
• func RemoveCondition(status *v1.ReplicationControllerStatus, condType v1.ReplicationControllerConditionType)
• func SetCondition(status *v1.ReplicationControllerStatus, condition v1.ReplicationControllerCondition)
• type ReplicationManager
• func NewReplicationManager(ctx context.Context, podInformer coreinformers.PodInformer, rcInformer coreinformers.ReplicationControllerInformer, kubeClient clientset.Interface, burstReplicas int) *ReplicationManager

Constants ¶

const (
	BurstReplicas = replicaset.BurstReplicas
)

Functions ¶

func GetCondition ¶

func GetCondition(status v1.ReplicationControllerStatus, condType v1.ReplicationControllerConditionType) *v1.ReplicationControllerCondition

GetCondition returns a replication controller condition with the provided type if it exists.

func RemoveCondition ¶

func RemoveCondition(status *v1.ReplicationControllerStatus, condType v1.ReplicationControllerConditionType)

RemoveCondition removes the condition with the provided type from the replication controller status.

func SetCondition ¶

func SetCondition(status *v1.ReplicationControllerStatus, condition v1.ReplicationControllerCondition)

SetCondition adds/replaces the given condition in the replication controller status.

Types ¶

type ReplicationManager ¶

type ReplicationManager struct {
	replicaset.ReplicaSetController
}

ReplicationManager is responsible for synchronizing ReplicationController objects stored in the system with actual running pods. It is actually just a wrapper around ReplicaSetController.

func NewReplicationManager ¶

func NewReplicationManager(ctx context.Context, podInformer coreinformers.PodInformer, rcInformer coreinformers.ReplicationControllerInformer, kubeClient clientset.Interface, burstReplicas int) *ReplicationManager

NewReplicationManager configures a replication manager with the specified event recorder

Source Files ¶

conversion.go doc.go replication_controller.go replication_controller_utils.go

Directories ¶