- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 51 for reconciliation (0.2 sec)
-
pkg/kubelet/volumemanager/reconciler/reconciler.go
} if len(rc.volumesNeedUpdateFromNodeStatus) == 0 { // ASW is fully populated only after both devicePaths and uncertain volume attach-ability // were reconstructed from the API server. // This will start reconciliation of node.status.volumesInUse. rc.updateLastSyncTime() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:23:12 UTC 2024 - 2.1K bytes - Viewed (0) -
pkg/controlplane/apiserver/peer.go
versionedInformer, svm, proxyRoundTripper, apiServerID, reconciler, serializer, ), nil } // CreatePeerEndpointLeaseReconciler creates a apiserver endpoint lease reconciliation loop // The peer endpoint leases are used to find network locations of apiservers for peer proxy
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 08:15:02 UTC 2024 - 3.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller.go
type controller[T runtime.Object] struct { informer Informer[T] queue workqueue.TypedRateLimitingInterface[string] // Returns an error if there was a transient error during reconciliation // and the object should be tried again later. reconciler func(namespace, name string, newObj T) error options ControllerOptions // must hold a func() bool or nil notificationsDelivered atomic.Value
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.5K bytes - Viewed (0) -
pkg/kubelet/status/status_manager_test.go
APIVersion: "v1", }, ObjectMeta: metav1.ObjectMeta{ UID: "12345678", Name: "foo", Namespace: "new", }, } } // After adding reconciliation, if status in pod manager is different from the cached status, a reconciliation // will be triggered, which will mess up all the old unit test. // To simplify the implementation of unit test, we add testSyncBatch() here, it will make sure the statuses in
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 16:27:19 UTC 2024 - 68.1K bytes - Viewed (0) -
pilot/pkg/config/monitor/monitor.go
// as files added to a directory immediately after creation may not trigger events; as such it is only useful // when an event causes a full reconciliation, rather than acting on an individual event type recursiveWatcher struct { *fsnotify.Watcher } // watchRecursive adds all directories under the given one to the watch list.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Feb 12 17:36:33 UTC 2024 - 7.2K bytes - Viewed (0) -
pilot/pkg/features/experimental.go
return 10 * time.Second } return val }() EnableStatus = env.Register( "PILOT_ENABLE_STATUS", false, "If enabled, pilot will update the CRD Status field of all istio resources with reconciliation status.", ).Get() EnableGatewayAPI = env.Register("PILOT_ENABLE_GATEWAY_API", true, "If this is set to true, support for Kubernetes gateway-api (github.com/kubernetes-sigs/gateway-api) will "+
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 17:02:38 UTC 2024 - 10.2K bytes - Viewed (0) -
pkg/kubelet/cm/dra/manager.go
) // draManagerStateFileName is the file name where dra manager stores its state const draManagerStateFileName = "dra_manager_state" // defaultReconcilePeriod is the default reconciliation period to keep all claim info state in sync. const defaultReconcilePeriod = 60 * time.Second // ActivePodsFunc is a function that returns a list of pods to reconcile. type ActivePodsFunc func() []*v1.Pod
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 13:23:29 UTC 2024 - 19.4K bytes - Viewed (0) -
common-protos/k8s.io/api/admissionregistration/v1beta1/generated.proto
// SideEffects states whether this webhook has side effects. // Acceptable values are: Unknown, None, Some, NoneOnDryRun // Webhooks with side effects MUST implement a reconciliation system, since a request may be // rejected by a future step in the admission chain and the side effects therefore need to be undone. // Requests with the dryRun attribute will be auto-rejected if they match a webhook with
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 22.6K bytes - Viewed (0) -
staging/src/k8s.io/api/rbac/v1/types.go
NonResourceAll = "*" GroupKind = "Group" ServiceAccountKind = "ServiceAccount" UserKind = "User" // AutoUpdateAnnotationKey is the name of an annotation which prevents reconciliation if set to "false" AutoUpdateAnnotationKey = "rbac.authorization.kubernetes.io/autoupdate" ) // Authorization is calculated against // 1. evaluation of ClusterRoleBindings - short circuit on match
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 23 17:42:49 UTC 2024 - 10.7K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
} for _, pod := range s.pods.List(namespace, klabels.Everything()) { // ztunnel pods are never "added to/removed from the mesh", so do not fire // spurious events for them to avoid triggering extra // ztunnel node reconciliation checks. if !util.IsZtunnelPod(s.systemNamespace, pod) { log.Debugf("Enqueuing pod %s/%s", pod.Namespace, pod.Name) s.queue.Add(controllers.Event{ New: pod, Old: pod,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 21:31:35 UTC 2024 - 11.8K bytes - Viewed (0)