- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 68 for Reconciled (0.15 sec)
-
pkg/controller/volume/attachdetach/attach_detach_controller.go
attacherDetacher operationexecutor.OperationExecutor // reconciler is used to run an asynchronous periodic loop to reconcile the // desiredStateOfWorld with the actualStateOfWorld by triggering attach // detach operations using the attacherDetacher. reconciler reconciler.Reconciler // nodeStatusUpdater is used to update node status with the list of attached // volumes
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.6K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/reconciler/reconciler_test.go
fakeRecorder, )) reconciler := NewReconciler( oex, reconcilerLoopSleepDuration, dsw, asw, ) reconciler.AddHandler(registerapi.DevicePlugin, cache.PluginHandler(di)) // Start the reconciler to fill ASW. stopChan := make(chan struct{}) defer close(stopChan) go reconciler.Run(stopChan) socketPath := filepath.Join(socketDir, "plugin.sock")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:21:15 UTC 2024 - 10.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/peerproxy/peerproxy_handler_test.go
baseKey := "/" + uuid.New().String() + "/peer-testleases/" leaseTime := 1 * time.Minute reconciler, err := reconcilers.NewPeerEndpointLeaseReconciler(&config, baseKey, leaseTime) if err != nil { t.Fatalf("Error creating storage: %v", err) } return reconciler } func newHandlerChain(t *testing.T, handler http.Handler, reconciler reconcilers.PeerEndpointLeaseReconciler, informerFinishedSync bool, svdata FakeSVMapData) http.Handler {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 10.8K bytes - Viewed (0) -
cmd/kube-apiserver/app/options/validation_test.go
wantErr bool }{ { name: "master endpoint reconciler - IPv4 families", extra: Extra{ EndpointReconcilerType: "master-count", PrimaryServiceClusterIPRange: *ipv4cidr, }, generic: apiserveroptions.ServerRunOptions{ AdvertiseAddress: ipv4address, }, wantErr: false, }, { name: "master endpoint reconciler - IPv6 families", extra: Extra{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 11.4K bytes - Viewed (0) -
operator/cmd/mesh/install.go
opts := &helmreconciler.Options{ DryRun: dryRun, Log: l, WaitTimeout: waitTimeout, ProgressLog: progress.NewLog(), Force: force, } reconciler, err := helmreconciler.NewHelmReconciler(client, kubeClient, iop, opts) if err != nil { return err } status, err := reconciler.Reconcile() if err != nil { return fmt.Errorf("errors occurred during operation: %v", err) } if status.Status != v1alpha1.InstallStatus_HEALTHY {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 21:52:35 UTC 2024 - 15.4K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconstruct_common.go
VolumeSpecName: gvi.volumeSpec.Name(), DevicePath: gvi.devicePath, PodVolumes: podVolumes, } } func (rc *reconciler) updateLastSyncTime() { rc.timeOfLastSyncLock.Lock() defer rc.timeOfLastSyncLock.Unlock() rc.timeOfLastSync = time.Now() } func (rc *reconciler) StatesHasBeenSynced() bool { rc.timeOfLastSyncLock.Lock() defer rc.timeOfLastSyncLock.Unlock() return !rc.timeOfLastSync.IsZero()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 14.1K bytes - Viewed (0) -
pkg/webhooks/validation/controller/controller.go
return c } func (c *Controller) Reconcile(key types.NamespacedName) error { name := key.Name whc := c.webhooks.Get(name, "") scope := scope.WithLabels("webhook", name) // Stop early if webhook is not present, rather than attempting (and failing) to reconcile permanently // If the webhook is later added a new reconciliation request will trigger it to update
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 28 16:52:19 UTC 2024 - 11.3K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/controller.go
}), ) } else { c.statusController.Store(nil) } } // Reconcile takes in a current snapshot of the gateway-api configs, and regenerates our internal state. // Any status updates required will be enqueued as well. func (c *Controller) Reconcile(ps *model.PushContext) error { t0 := time.Now() defer func() { log.Debugf("reconcile complete in %v", time.Since(t0)) }()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 05:26:03 UTC 2024 - 13.5K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
"istio.io/istio/pkg/monitoring" ) var ( eventTypeTag = monitoring.CreateLabel("type") EventTotals = monitoring.NewSum( "nodeagent_reconcile_events_total", "The total number of node agent reconcile events.", ) ) type K8sHandlers interface { GetPodIfAmbient(podName, podNamespace string) (*corev1.Pod, error) GetActiveAmbientPodSnapshot() []*corev1.Pod Start() } type InformerHandlers struct {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 21:31:35 UTC 2024 - 11.8K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
types.MergePatchType, labelsPatch, metav1.PatchOptions{}) assert.NoError(t, err) // wait for another two update events // total 3 update at before unlabel point: 1. init ns reconcile 2. ns label reconcile 3. pod annotation update mt.Assert(EventTotals.Name(), map[string]string{"type": "update"}, monitortest.AtLeast(5)) waitForMockCalls() assertPodNotAnnotated(t, client, pod)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 22.2K bytes - Viewed (0)