- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 1,244 for syncFn (0.13 sec)
-
pilot/pkg/serviceregistry/aggregate/controller.go
c.storeLock.Unlock() <-stop log.Info("Registry Aggregator terminated") } // HasSynced returns true when all registries have synced func (c *Controller) HasSynced() bool { for _, r := range c.GetRegistries() { if !r.HasSynced() { log.Debugf("registry %s is syncing", r.Cluster()) return false } } return true } func (c *Controller) AppendServiceHandler(f model.ServiceHandler) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 06:28:11 UTC 2024 - 13.5K bytes - Viewed (0) -
src/internal/pkgbits/syncmarker_string.go
_ = x[SyncFuncExt-30] _ = x[SyncVarExt-31] _ = x[SyncTypeExt-32] _ = x[SyncPragma-33] _ = x[SyncExprList-34] _ = x[SyncExprs-35] _ = x[SyncExpr-36] _ = x[SyncExprType-37] _ = x[SyncAssign-38] _ = x[SyncOp-39] _ = x[SyncFuncLit-40] _ = x[SyncCompLit-41] _ = x[SyncDecl-42] _ = x[SyncFuncBody-43] _ = x[SyncOpenScope-44] _ = x[SyncCloseScope-45] _ = x[SyncCloseAnotherScope-46] _ = x[SyncDeclNames-47]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 11 20:24:07 UTC 2023 - 2.9K bytes - Viewed (0) -
pkg/kube/controllers/queue.go
key, quit := q.queue.Get() if quit { // We are done, signal to exit the queue return false } // We got the sync signal. This is not a real event, so we exit early after signaling we are synced if key == defaultSyncSignal { q.log.Debugf("synced") q.initialSync.Store(true) return true } q.log.Debugf("handling update: %v", formatKey(key))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 08 16:43:05 UTC 2023 - 6.3K bytes - Viewed (0) -
pkg/controller/certificates/rootcacertpublisher/publisher.go
utilruntime.HandleError(fmt.Errorf("syncing %q failed: %v", key, err)) c.queue.AddRateLimited(key) return true } c.queue.Forget(key) return true } func (c *Publisher) syncNamespace(ctx context.Context, ns string) (err error) { startTime := time.Now() defer func() { recordMetrics(startTime, err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.8K bytes - Viewed (0) -
pkg/kubelet/clustertrustbundle/clustertrustbundle_manager.go
func (m *InformerManager) GetTrustAnchorsByName(name string, allowMissing bool) ([]byte, error) { if !m.ctbInformer.HasSynced() { return nil, fmt.Errorf("ClusterTrustBundle informer has not yet synced") } cacheKey := cacheKeyType{ctbName: name} if cachedAnchors, ok := m.normalizationCache.Get(cacheKey); ok { return cachedAnchors.([]byte), nil } ctb, err := m.ctbLister.Get(name)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 03 18:40:48 UTC 2023 - 8.3K bytes - Viewed (0) -
cmd/kube-controller-manager/app/options/validatingadmissionpolicycontroller.go
if o == nil { return } fs.Int32Var(&o.ConcurrentPolicySyncs, "concurrent-validating-admission-policy-status-syncs", o.ConcurrentPolicySyncs, "The number of ValidatingAdmissionPolicyStatusController workers that are allowed to sync concurrently.") } // ApplyTo fills up ValidatingAdmissionPolicyStatusController config with options.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 13 20:41:50 UTC 2023 - 2.2K bytes - Viewed (0) -
pilot/pkg/config/kube/crdclient/client.go
cl.logger.Errorf("Failed to sync Pilot K8S CRD controller cache") return } cl.logger.Infof("Pilot K8S CRD controller synced in %v", time.Since(t0)) cl.queue.Run(stop) cl.logger.Infof("controller terminated") } func (cl *Client) informerSynced() bool { for gk, ctl := range cl.allKinds() { if !ctl.HasSynced() { cl.logger.Infof("controller %q is syncing...", gk) return false } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 00:12:28 UTC 2024 - 13.7K bytes - Viewed (0) -
pkg/kubelet/pleg/pleg.go
ContainerDied PodLifeCycleEventType = "ContainerDied" // ContainerRemoved - event type when the old state of container is exited. ContainerRemoved PodLifeCycleEventType = "ContainerRemoved" // PodSync is used to trigger syncing of a pod when the observed change of // the state of the pod cannot be captured by any single event above. PodSync PodLifeCycleEventType = "PodSync" // ContainerChanged - event type when the new state of container is unknown.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 26 16:14:26 UTC 2023 - 2.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller.go
if !cache.WaitForNamedCacheSync(c.options.Name, ctx.Done(), c.informer.HasSynced) { // ctx cancelled during cache sync. return early err := ctx.Err() if err == nil { // if context wasnt cancelled then the sync failed for another reason err = errors.New("cache sync failed") } return err } waitGroup := sync.WaitGroup{} for i := uint(0); i < c.options.Workers; i++ { waitGroup.Add(1) go func() {
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/registry/core/service/ipallocator/controller/repairip.go
if !cache.WaitForNamedCacheSync("ipallocator-repair-controller", stopCh, r.ipAddressSynced, r.servicesSynced, r.serviceCIDRSynced) { return } // First sync goes through all the Services and IPAddresses in the cache, // once synced, it signals the main loop and works using the handlers, since // it's less expensive and more optimal. if err := r.runOnce(); err != nil { runtime.HandleError(err) return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.7K bytes - Viewed (0)