const BurstReplicas … const statusUpdateRetries … const controllerUIDIndex … type ReplicaSetController … // NewReplicaSetController configures a replica set controller with the specified event recorder func NewReplicaSetController(ctx context.Context, rsInformer appsinformers.ReplicaSetInformer, podInformer coreinformers.PodInformer, kubeClient clientset.Interface, burstReplicas int) *ReplicaSetController { … } // NewBaseController is the implementation of NewReplicaSetController with additional injected // parameters so that it can also serve as the implementation of NewReplicationController. func NewBaseController(logger klog.Logger, rsInformer appsinformers.ReplicaSetInformer, podInformer coreinformers.PodInformer, kubeClient clientset.Interface, burstReplicas int, gvk schema.GroupVersionKind, metricOwnerName, queueName string, podControl controller.PodControlInterface, eventBroadcaster record.EventBroadcaster) *ReplicaSetController { … } // Run begins watching and syncing. func (rsc *ReplicaSetController) Run(ctx context.Context, workers int) { … } // getReplicaSetsWithSameController returns a list of ReplicaSets with the same // owner as the given ReplicaSet. func (rsc *ReplicaSetController) getReplicaSetsWithSameController(logger klog.Logger, rs *apps.ReplicaSet) []*apps.ReplicaSet { … } // getPodReplicaSets returns a list of ReplicaSets matching the given pod. func (rsc *ReplicaSetController) getPodReplicaSets(pod *v1.Pod) []*apps.ReplicaSet { … } // resolveControllerRef returns the controller referenced by a ControllerRef, // or nil if the ControllerRef could not be resolved to a matching controller // of the correct Kind. func (rsc *ReplicaSetController) resolveControllerRef(namespace string, controllerRef *metav1.OwnerReference) *apps.ReplicaSet { … } func (rsc *ReplicaSetController) enqueueRS(rs *apps.ReplicaSet) { … } func (rsc *ReplicaSetController) enqueueRSAfter(rs *apps.ReplicaSet, duration time.Duration) { … } func (rsc *ReplicaSetController) addRS(logger klog.Logger, obj interface{ … } // callback when RS is updated func (rsc *ReplicaSetController) updateRS(logger klog.Logger, old, cur interface{ … } func (rsc *ReplicaSetController) deleteRS(logger klog.Logger, obj interface{ … } // When a pod is created, enqueue the replica set that manages it and update its expectations. func (rsc *ReplicaSetController) addPod(logger klog.Logger, obj interface{ … } // When a pod is updated, figure out what replica set/s manage it and wake them // up. If the labels of the pod have changed we need to awaken both the old // and new replica set. old and cur must be *v1.Pod types. func (rsc *ReplicaSetController) updatePod(logger klog.Logger, old, cur interface{ … } // When a pod is deleted, enqueue the replica set that manages the pod and update its expectations. // obj could be an *v1.Pod, or a DeletionFinalStateUnknown marker item. func (rsc *ReplicaSetController) deletePod(logger klog.Logger, obj interface{ … } // worker runs a worker thread that just dequeues items, processes them, and marks them done. // It enforces that the syncHandler is never invoked concurrently with the same key. func (rsc *ReplicaSetController) worker(ctx context.Context) { … } func (rsc *ReplicaSetController) processNextWorkItem(ctx context.Context) bool { … } // manageReplicas checks and updates replicas for the given ReplicaSet. // Does NOT modify <filteredPods>. // It will requeue the replica set in case of an error while creating/deleting pods. func (rsc *ReplicaSetController) manageReplicas(ctx context.Context, filteredPods []*v1.Pod, rs *apps.ReplicaSet) error { … } // syncReplicaSet will sync the ReplicaSet with the given key if it has had its expectations fulfilled, // meaning it did not expect to see any more of its pods created or deleted. This function is not meant to be // invoked concurrently with the same key. func (rsc *ReplicaSetController) syncReplicaSet(ctx context.Context, key string) error { … } func (rsc *ReplicaSetController) claimPods(ctx context.Context, rs *apps.ReplicaSet, selector labels.Selector, filteredPods []*v1.Pod) ([]*v1.Pod, error) { … } // slowStartBatch tries to call the provided function a total of 'count' times, // starting slow to check for errors, then speeding up if calls succeed. // // It groups the calls into batches, starting with a group of initialBatchSize. // Within each batch, it may call the function multiple times concurrently. // // If a whole batch succeeds, the next batch may get exponentially larger. // If there are any failures in a batch, all remaining batches are skipped // after waiting for the current batch to complete. // // It returns the number of successful calls to the function. func slowStartBatch(count int, initialBatchSize int, fn func() error) (int, error) { … } // getIndirectlyRelatedPods returns all pods that are owned by any ReplicaSet // that is owned by the given ReplicaSet's owner. func (rsc *ReplicaSetController) getIndirectlyRelatedPods(logger klog.Logger, rs *apps.ReplicaSet) ([]*v1.Pod, error) { … } func getPodsToDelete(filteredPods, relatedPods []*v1.Pod, diff int) []*v1.Pod { … } func reportSortingDeletionAgeRatioMetric(filteredPods []*v1.Pod, diff int) { … } // getPodsRankedByRelatedPodsOnSameNode returns an ActivePodsWithRanks value // that wraps podsToRank and assigns each pod a rank equal to the number of // active pods in relatedPods that are colocated on the same node with the pod. // relatedPods generally should be a superset of podsToRank. func getPodsRankedByRelatedPodsOnSameNode(podsToRank, relatedPods []*v1.Pod) controller.ActivePodsWithRanks { … } func getPodKeys(pods []*v1.Pod) []string { … }
Codebase Browser
kubernetes