- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 2,460 for syncs (0.26 sec)
-
cni/pkg/nodeagent/net.go
// // 1. Constructs a ztunnel state message to initialize ztunnel // 2. Syncs the host ipset func (s *NetServer) ConstructInitialSnapshot(ambientPods []*corev1.Pod) error { var consErr []error if err := s.syncHostIPSets(ambientPods); err != nil { log.Warnf("failed to sync host IPset: %v", err) consErr = append(consErr, err) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 13.4K bytes - Viewed (0) -
pkg/kubelet/cm/dra/plugin/noderesources.go
} } // run is running in the background. It handles blocking initialization (like // syncing the informer) and then syncs the actual with the desired state. func (c *nodeResourcesController) run(ctx context.Context) { logger := klog.FromContext(ctx) // When kubelet starts, we have two choices: // - Sync immediately, which in practice will delete all ResourceSlices
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 20:12:53 UTC 2024 - 16.6K bytes - Viewed (0) -
pkg/kube/client.go
// ms, but we are delayed a full 100ms. This is especially apparent in tests, which previously spent // most of their time just in the 100ms wait interval. // // To optimize this, this function performs exponential backoff. This is generally safe because // cache.InformerSynced functions are ~always quick to run. However, if the sync functions do perform
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 14:44:17 UTC 2024 - 39K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/endpointslicemirroring_controller.go
if !c.shouldMirror(endpoints) { logger.V(5).Info("Skipping mirroring", "endpoints", klog.KObj(endpoints)) return } c.queueEndpoints(obj) } // onEndpointSliceAdd queues a sync for the relevant Endpoints resource for a // sync if the EndpointSlice resource version does not match the expected // version in the endpointSliceTracker. func (c *Controller) onEndpointSliceAdd(obj interface{}) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 06 23:18:31 UTC 2024 - 20.1K bytes - Viewed (0) -
cmd/kubeadm/app/util/etcd/etcd.go
continue } etcdEndpoints = append(etcdEndpoints, etcdEndpoint) } return etcdEndpoints, len(podList.Items), nil } // Sync synchronizes client's endpoints with the known endpoints from the etcd membership. func (c *Client) Sync() error { // Syncs the list of endpoints var cli etcdClient var lastError error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 11:04:08 UTC 2024 - 21.2K bytes - Viewed (0) -
pkg/controller/resourcequota/resource_quota_controller.go
rq.enqueueResourceQuota(logger, resourceQuota) } } } // Sync periodically resyncs the controller when new resources are observed from discovery. func (rq *Controller) Sync(ctx context.Context, discoveryFunc NamespacedResourcesFunc, period time.Duration) { // Something has changed, so track the new state and perform a sync. oldResources := make(map[schema.GroupVersionResource]struct{})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 21.3K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller.go
if err != nil { utilruntime.HandleError(fmt.Errorf("Couldn't get key for object %+v: %v", obj, err)) return } c.serviceQueue.Add(key) } // onEndpointSliceAdd queues a sync for the relevant Service for a sync if the // EndpointSlice resource version does not match the expected version in the // endpointSliceTracker. func (c *Controller) onEndpointSliceAdd(obj interface{}) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 23.6K bytes - Viewed (0) -
cluster/gce/config-default.sh
# Optional: enable certificate rotation of the kubelet certificates. ROTATE_CERTIFICATES="${ROTATE_CERTIFICATES:-}" # The number of services that are allowed to sync concurrently. Will be passed # into kube-controller-manager via `--concurrent-service-syncs` CONCURRENT_SERVICE_SYNCS="${CONCURRENT_SERVICE_SYNCS:-5}" export SERVICEACCOUNT_ISSUER="https://kubernetes.io/${CLUSTER_NAME}"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 20:16:32 UTC 2024 - 26.9K bytes - Viewed (0) -
cluster/gce/config-test.sh
# Optional: enable certificate rotation of the kubelet certificates. ROTATE_CERTIFICATES=${ROTATE_CERTIFICATES:-} # The number of services that are allowed to sync concurrently. Will be passed # into kube-controller-manager via `--concurrent-service-syncs` CONCURRENT_SERVICE_SYNCS=${CONCURRENT_SERVICE_SYNCS:-5} # The value kubernetes.default.svc.cluster.local is only usable for full
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 17:20:24 UTC 2024 - 29.8K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/init.go
if len(d.patchesDir) > 0 { return d.patchesDir } if d.cfg.Patches != nil { return d.cfg.Patches.Directory } return "" } // manageSkippedAddons syncs proxy and DNS "Disabled" status and skipPhases. func manageSkippedAddons(cfg *kubeadmapi.ClusterConfiguration, skipPhases []string) []string { var ( skipDNSPhase = false skipProxyPhase = false )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 17 03:37:05 UTC 2024 - 24.1K bytes - Viewed (0)