const defaultNodeMaskCIDRIPv4 … const defaultNodeMaskCIDRIPv6 … func newServiceLBControllerDescriptor() *ControllerDescriptor { … } func startServiceLBController(ctx context.Context, controllerContext ControllerContext, controllerName string) (controller.Interface, bool, error) { … } func newNodeIpamControllerDescriptor() *ControllerDescriptor { … } func startNodeIpamController(ctx context.Context, controllerContext ControllerContext, controllerName string) (controller.Interface, bool, error) { … } func newNodeLifecycleControllerDescriptor() *ControllerDescriptor { … } func startNodeLifecycleController(ctx context.Context, controllerContext ControllerContext, controllerName string) (controller.Interface, bool, error) { … } func newTaintEvictionControllerDescriptor() *ControllerDescriptor { … } func startTaintEvictionController(ctx context.Context, controllerContext ControllerContext, controllerName string) (controller.Interface, bool, error) { … } func newCloudNodeLifecycleControllerDescriptor() *ControllerDescriptor { … } func startCloudNodeLifecycleController(ctx context.Context, controllerContext ControllerContext, controllerName string) (controller.Interface, bool, error) { … } func newNodeRouteControllerDescriptor() *ControllerDescriptor { … } func startNodeRouteController(ctx context.Context, controllerContext ControllerContext, controllerName string) (controller.Interface, bool, error) { … } func newPersistentVolumeBinderControllerDescriptor() *ControllerDescriptor { … } func startPersistentVolumeBinderController(ctx context.Context, controllerContext ControllerContext, controllerName string) (controller.Interface, bool, error) { … } func newPersistentVolumeAttachDetachControllerDescriptor() *ControllerDescriptor { … } func startPersistentVolumeAttachDetachController(ctx context.Context, controllerContext ControllerContext, controllerName string) (controller.Interface, bool, error) { … } func newPersistentVolumeExpanderControllerDescriptor() *ControllerDescriptor { … } func startPersistentVolumeExpanderController(ctx context.Context, controllerContext ControllerContext, controllerName string) (controller.Interface, bool, error) { … } func newEphemeralVolumeControllerDescriptor() *ControllerDescriptor { … } func startEphemeralVolumeController(ctx context.Context, controllerContext ControllerContext, controllerName string) (controller.Interface, bool, error) { … } const defaultResourceClaimControllerWorkers … func newResourceClaimControllerDescriptor() *ControllerDescriptor { … } func startResourceClaimController(ctx context.Context, controllerContext ControllerContext, controllerName string) (controller.Interface, bool, error) { … } func newEndpointsControllerDescriptor() *ControllerDescriptor { … } func startEndpointsController(ctx context.Context, controllerContext ControllerContext, controllerName string) (controller.Interface, bool, error) { … } func newReplicationControllerDescriptor() *ControllerDescriptor { … } func startReplicationController(ctx context.Context, controllerContext ControllerContext, controllerName string) (controller.Interface, bool, error) { … } func newPodGarbageCollectorControllerDescriptor() *ControllerDescriptor { … } func startPodGarbageCollectorController(ctx context.Context, controllerContext ControllerContext, controllerName string) (controller.Interface, bool, error) { … } func newResourceQuotaControllerDescriptor() *ControllerDescriptor { … } func startResourceQuotaController(ctx context.Context, controllerContext ControllerContext, controllerName string) (controller.Interface, bool, error) { … } func newNamespaceControllerDescriptor() *ControllerDescriptor { … } func startNamespaceController(ctx context.Context, controllerContext ControllerContext, controllerName string) (controller.Interface, bool, error) { … } func startModifiedNamespaceController(ctx context.Context, controllerContext ControllerContext, namespaceKubeClient clientset.Interface, nsKubeconfig *restclient.Config) (controller.Interface, bool, error) { … } func newServiceAccountControllerDescriptor() *ControllerDescriptor { … } func startServiceAccountController(ctx context.Context, controllerContext ControllerContext, controllerName string) (controller.Interface, bool, error) { … } func newTTLControllerDescriptor() *ControllerDescriptor { … } func startTTLController(ctx context.Context, controllerContext ControllerContext, controllerName string) (controller.Interface, bool, error) { … } func newGarbageCollectorControllerDescriptor() *ControllerDescriptor { … } func startGarbageCollectorController(ctx context.Context, controllerContext ControllerContext, controllerName string) (controller.Interface, bool, error) { … } func newPersistentVolumeClaimProtectionControllerDescriptor() *ControllerDescriptor { … } func startPersistentVolumeClaimProtectionController(ctx context.Context, controllerContext ControllerContext, controllerName string) (controller.Interface, bool, error) { … } func newPersistentVolumeProtectionControllerDescriptor() *ControllerDescriptor { … } func startPersistentVolumeProtectionController(ctx context.Context, controllerContext ControllerContext, controllerName string) (controller.Interface, bool, error) { … } func newTTLAfterFinishedControllerDescriptor() *ControllerDescriptor { … } func startTTLAfterFinishedController(ctx context.Context, controllerContext ControllerContext, controllerName string) (controller.Interface, bool, error) { … } func newLegacyServiceAccountTokenCleanerControllerDescriptor() *ControllerDescriptor { … } func startLegacyServiceAccountTokenCleanerController(ctx context.Context, controllerContext ControllerContext, controllerName string) (controller.Interface, bool, error) { … } // processCIDRs is a helper function that works on a comma separated cidrs and returns // a list of typed cidrs // error if failed to parse any of the cidrs or invalid length of cidrs func validateCIDRs(cidrsList string) ([]*net.IPNet, error) { … } // processCIDRs is a helper function that works on a comma separated cidrs and returns // a list of typed cidrs // a flag if cidrs represents a dual stack // error if failed to parse any of the cidrs func processCIDRs(cidrsList string) ([]*net.IPNet, bool, error) { … } // setNodeCIDRMaskSizes returns the IPv4 and IPv6 node cidr mask sizes to the value provided // for --node-cidr-mask-size-ipv4 and --node-cidr-mask-size-ipv6 respectively. If value not provided, // then it will return default IPv4 and IPv6 cidr mask sizes. func setNodeCIDRMaskSizes(cfg nodeipamconfig.NodeIPAMControllerConfiguration, clusterCIDRs []*net.IPNet) ([]int, error) { … } func newStorageVersionGarbageCollectorControllerDescriptor() *ControllerDescriptor { … } func startStorageVersionGarbageCollectorController(ctx context.Context, controllerContext ControllerContext, controllerName string) (controller.Interface, bool, error) { … }
Codebase Browser
kubernetes