- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 1,244 for syncFn (0.14 sec)
-
pkg/kube/informerfactory/factory.go
} type informerFactory struct { lock sync.Mutex informers map[informerKey]builtInformer // startedInformers is used for tracking which informers have been started. // This allows Start() to be called multiple times safely. startedInformers sets.Set[informerKey] // wg tracks how many goroutines were started. wg sync.WaitGroup
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 7.9K bytes - Viewed (0) -
cmd/kube-controller-manager/app/options/deploymentcontroller.go
func (o *DeploymentControllerOptions) AddFlags(fs *pflag.FlagSet) { if o == nil { return } fs.Int32Var(&o.ConcurrentDeploymentSyncs, "concurrent-deployment-syncs", o.ConcurrentDeploymentSyncs, "The number of deployment objects that are allowed to sync concurrently. Larger number = more responsive deployments, but more CPU (and network) load") } // ApplyTo fills up DeploymentController config with options.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 30 12:00:53 UTC 2022 - 1.8K bytes - Viewed (0) -
pkg/kubelet/volume_host.go
} // WaitForCacheSync is a helper function that waits for cache sync for CSIDriverLister func (kvh *kubeletVolumeHost) WaitForCacheSync() error { if kvh.csiDriversSynced == nil { klog.ErrorS(nil, "CsiDriversSynced not found on KubeletVolumeHost") return fmt.Errorf("csiDriversSynced not found on KubeletVolumeHost") } synced := []cache.InformerSynced{kvh.csiDriversSynced}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 10K bytes - Viewed (0) -
platforms/documentation/docs/src/docs/userguide/img/android-studio-build-sync-popup.png
android-studio-build-sync-popup.png...
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Nov 27 17:53:42 UTC 2023 - 7.5K bytes - Viewed (0) -
cmd/kube-controller-manager/app/options/hpacontroller.go
fs.DurationVar(&o.HorizontalPodAutoscalerSyncPeriod.Duration, "horizontal-pod-autoscaler-sync-period", o.HorizontalPodAutoscalerSyncPeriod.Duration, "The period for syncing...
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun May 19 09:49:23 UTC 2024 - 3.8K bytes - Viewed (0) -
pkg/security/apparmor/helpers.go
} if container.SecurityContext != nil && container.SecurityContext.AppArmorProfile != nil { return container.SecurityContext.AppArmorProfile } // Static pods may not have had annotations synced to fields, so fallback to annotations before // the pod profile. if profile := getProfileFromPodAnnotations(pod.Annotations, container.Name); profile != nil { return profile }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 18:46:32 UTC 2024 - 3.5K bytes - Viewed (0) -
pkg/proxy/servicechangetracker.go
type processServiceMapChangeFunc func(previous, current ServicePortMap) // serviceChange contains all changes to services that happened since proxy rules were synced. For a single object, // changes are accumulated, i.e. previous is state from before applying the changes, // current is state after applying all of the changes. type serviceChange struct { previous ServicePortMap
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 21 14:44:08 UTC 2023 - 8.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_test_context.go
return fmt.Errorf("timed out waiting for initial cache sync") } return nil } return res, testCancel, nil } // UpdateAndWait updates the given object in the test, or creates it if it doesn't exist // Depending upon object type, waits afterward until the object is synced // by the policy source // // Be aware the UpdateAndWait will modify the ResourceVersion of the
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 19K bytes - Viewed (0) -
pkg/proxy/iptables/proxier.go
defer proxier.mu.Unlock() // don't sync rules till we've received services and endpoints if !proxier.isInitialized() { proxier.logger.V(2).Info("Not syncing iptables until Services and Endpoints have been received from master") return } // The value of proxier.needFullSync may change before the defer funcs run, so // we need to keep track of whether it was set at the *start* of the sync. tryPartialSync := !proxier.needFullSync
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 65.1K bytes - Viewed (0) -
pilot/pkg/xds/statusgen.go
// TypeDebugSyncronization requests Envoy CSDS for proxy sync status TypeDebugSyncronization = v3.DebugType + "/syncz" // TypeDebugConfigDump requests Envoy configuration for a proxy without creating one TypeDebugConfigDump = v3.DebugType + "/config_dump" // TODO: TypeURLReady - readiness events for endpoints, agent can propagate ) // StatusGen is a Generator for XDS status: connections, syncz, configdump type StatusGen struct {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jan 10 23:30:28 UTC 2024 - 5.6K bytes - Viewed (0)