Documentation ¶
Overview ¶
Package replicaset contains logic for watching and synchronizing ReplicaSets.
Index ¶
- Constants
- func GetCondition(status extensions.ReplicaSetStatus, ...) *extensions.ReplicaSetCondition
- func NewReplicaSetCondition(condType extensions.ReplicaSetConditionType, status v1.ConditionStatus, ...) extensions.ReplicaSetCondition
- func RemoveCondition(status *extensions.ReplicaSetStatus, ...)
- func SetCondition(status *extensions.ReplicaSetStatus, condition extensions.ReplicaSetCondition)
- type ReplicaSetController
Constants ¶
const ( // Realistic value of the burstReplica field for the replica set manager based off // performance requirements for kubernetes 1.0. BurstReplicas = 500 )
Variables ¶
This section is empty.
Functions ¶
func GetCondition ¶ added in v1.5.1
func GetCondition(status extensions.ReplicaSetStatus, condType extensions.ReplicaSetConditionType) *extensions.ReplicaSetCondition
GetCondition returns a replicaset condition with the provided type if it exists.
func NewReplicaSetCondition ¶ added in v1.5.1
func NewReplicaSetCondition(condType extensions.ReplicaSetConditionType, status v1.ConditionStatus, reason, msg string) extensions.ReplicaSetCondition
NewReplicaSetCondition creates a new replicaset condition.
func RemoveCondition ¶ added in v1.5.1
func RemoveCondition(status *extensions.ReplicaSetStatus, condType extensions.ReplicaSetConditionType)
RemoveCondition removes the condition with the provided type from the replicaset status.
func SetCondition ¶ added in v1.5.1
func SetCondition(status *extensions.ReplicaSetStatus, condition extensions.ReplicaSetCondition)
SetCondition adds/replaces the given condition in the replicaset 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 ReplicaSetController ¶
type ReplicaSetController struct { // GroupVersionKind indicates the controller type. // Different instances of this struct may handle different GVKs. // For example, this struct can be used (with adapters) to handle ReplicationController. schema.GroupVersionKind // contains filtered or unexported fields }
ReplicaSetController is responsible for synchronizing ReplicaSet objects stored in the system with actual running pods.
func NewBaseController ¶ added in v1.9.1
func NewBaseController(rsInformer extensionsinformers.ReplicaSetInformer, podInformer coreinformers.PodInformer, kubeClient clientset.Interface, burstReplicas int, gvk schema.GroupVersionKind, metricOwnerName, queueName string, podControl controller.PodControlInterface) *ReplicaSetController
NewBaseController is the implementation of NewReplicaSetController with additional injected parameters so that it can also serve as the implementation of NewReplicationController.
func NewReplicaSetController ¶
func NewReplicaSetController(rsInformer extensionsinformers.ReplicaSetInformer, podInformer coreinformers.PodInformer, kubeClient clientset.Interface, burstReplicas int) *ReplicaSetController
NewReplicaSetController configures a replica set controller with the specified event recorder
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.