- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 108 for Reconciled (0.12 sec)
-
staging/src/k8s.io/api/core/v1/types.go
) // ModifyVolumeStatus represents the status object of ControllerModifyVolume operation type ModifyVolumeStatus struct { // targetVolumeAttributesClassName is the name of the VolumeAttributesClass the PVC currently being reconciled TargetVolumeAttributesClassName string `json:"targetVolumeAttributesClassName,omitempty" protobuf:"bytes,1,opt,name=targetVolumeAttributesClassName"`
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 390.8K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/operation_generator.go
// At this point, MountVolume.Setup already succeeded, we should add volume into actual state // so that reconciler can clean up volume when needed. However, volume resize failed, // we should not mark the volume as mounted to avoid pod starts using it. // Considering the above situations, we mark volume as uncertain here so that reconciler will trigger // volume tear down when pod is deleted, and also makes sure pod will not start using it.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 101.4K bytes - Viewed (0) -
pilot/pkg/model/context.go
} type GatewayController interface { ConfigStoreController // Reconcile updates the internal state of the gateway controller for a given input. This should be // called before any List/Get calls if the state has changed Reconcile(ctx *PushContext) error // SecretAllowed determines if a SDS credential is accessible to a given namespace.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 33.6K bytes - Viewed (0) -
pkg/controlplane/controller/clusterauthenticationtrust/cluster_authentication_trust_controller.go
if c.NotAfter.After(fiveMinutesAgo) { validCerts = append(validCerts, c) } } return validCerts } // Enqueue a method to allow separate control loops to cause the controller to trigger and reconcile content. func (c *Controller) Enqueue() { c.queue.Add(keyFn()) } // Run the controller until stopped. func (c *Controller) Run(ctx context.Context, workers int) { defer utilruntime.HandleCrash()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 18.2K bytes - Viewed (0) -
pkg/kubelet/volumemanager/cache/actual_state_of_world.go
asw.Lock() defer asw.Unlock() volumeObj, volumeExists := asw.attachedVolumes[volumeName] if !volumeExists { return } if volumeObj.deviceMountState != operationexecutor.DeviceMountUncertain { // Reconciler must have updated volume state, i.e. when a pod uses the volume and // succeeded mounting the volume. Such update has fixed the device path. return } volumeObj.devicePath = devicePath
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 45.8K bytes - Viewed (0) -
pkg/controller/nodeipam/ipam/range_allocator.go
// we don't see the Update with DeletionTimestamp != 0. // TODO: instead of executing the operation directly in the handler, build a small cache with key node.Name // and value PodCIDRs use ReleaseCIDR on the reconcile loop so we can retry on `ReleaseCIDR` failures. if err := ra.ReleaseCIDR(logger, obj.(*v1.Node)); err != nil { utilruntime.HandleError(fmt.Errorf("error while processing CIDR Release: %w", err)) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 10:06:15 UTC 2024 - 16.2K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set.go
logger.V(4).Info("Pod deleted.", "pod", klog.KObj(pod), "caller", utilruntime.GetCaller()) ssc.enqueueStatefulSet(set) } // getPodsForStatefulSet returns the Pods that a given StatefulSet should manage. // It also reconciles ControllerRef by adopting/orphaning. // // NOTE: Returned Pods are pointers to objects from the cache. // If you need to modify one, you need to copy it first.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 18.5K bytes - Viewed (0) -
pkg/kubelet/volumemanager/populator/desired_state_of_world_populator_test.go
podName, expectedVolumeName, "" /* SELinuxContext */); !podExistsInVolume { t.Fatalf( "DSW PodExistsInVolume returned incorrect value. Expected: <true> Actual: <%v>", podExistsInVolume) } // reconcile with actual state so that volume is added into the actual state // desired state populator now can successfully delete the pod and volume reconcileASW(fakeASW, dswp.desiredStateOfWorld, t) dswp.findAndRemoveDeletedPods()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 51.4K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller.go
dsc.enqueueDaemonSet(ds) } } } // getDaemonPods returns daemon pods owned by the given ds. // This also reconciles ControllerRef by adopting/orphaning. // Note that returned Pods are pointers to objects in the cache. // If you want to modify one, you need to deep-copy it first.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.3K bytes - Viewed (0) -
pkg/controller/deployment/deployment_controller.go
utilruntime.HandleError(err) logger.V(2).Info("Dropping deployment out of the queue", "deployment", klog.KRef(ns, name), "err", err) dc.queue.Forget(key) } // getReplicaSetsForDeployment uses ControllerRefManager to reconcile // ControllerRef by adopting and orphaning. // It returns the list of ReplicaSets that this Deployment should manage.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.2K bytes - Viewed (0)