- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 481 for syncFn (0.19 sec)
-
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/establish/establishing_controller.go
return false } defer ec.queue.Done(key) err := ec.syncFn(key) if err == nil { ec.queue.Forget(key) return true } utilruntime.HandleError(fmt.Errorf("%v failed with: %v", key, err)) ec.queue.AddRateLimited(key) return true } // sync is used to turn CRDs into the Established state. func (ec *EstablishingController) sync(key string) error { cachedCRD, err := ec.crdLister.Get(key)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 4.4K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/apiapproval/apiapproval_controller.go
// To allow injection for testing. syncFn func(key string) error queue workqueue.TypedRateLimitingInterface[string] // last protectedAnnotation value this controller updated the condition per CRD name (to avoid two // different version of the apiextensions-apiservers in HA to fight for the right message) lastSeenProtectedAnnotationLock sync.Mutex lastSeenProtectedAnnotation map[string]string }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.2K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/nonstructuralschema/nonstructuralschema_controller.go
crdSynced cache.InformerSynced // To allow injection for testing. syncFn func(key string) error queue workqueue.TypedRateLimitingInterface[string] // last generation this controller updated the condition per CRD name (to avoid two // different version of the apiextensions-apiservers in HA to fight for the right message) lastSeenGenerationLock sync.Mutex lastSeenGeneration map[string]int64 }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.3K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapiv3/controller.go
crdLister listers.CustomResourceDefinitionLister crdsSynced cache.InformerSynced // To allow injection for testing. syncFn func(string) error queue workqueue.TypedRateLimitingInterface[string] openAPIV3Service *handler3.OpenAPIService // specs per version and per CRD name lock sync.Mutex specsByGVandName map[schema.GroupVersion]map[string]*spec3.OpenAPI }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.9K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapi/controller.go
crdsSynced cache.InformerSynced // To allow injection for testing. syncFn func(string) error queue workqueue.TypedRateLimitingInterface[string] staticSpec *spec.Swagger openAPIService *handler.OpenAPIService // specs by name. The specs are lazily constructed on request. // The lock is for the map only. lock sync.Mutex specsByName map[string]*specCache }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.6K bytes - Viewed (0) -
pkg/kube/krt/sync.go
import "istio.io/istio/pkg/kube" type Syncer interface { WaitUntilSynced(stop <-chan struct{}) bool HasSynced() bool } var ( _ Syncer = channelSyncer{} _ Syncer = pollSyncer{} ) type channelSyncer struct { name string synced <-chan struct{} } func (c channelSyncer) WaitUntilSynced(stop <-chan struct{}) bool { return waitForCacheSync(c.name, stop, c.synced) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 03 14:25:07 UTC 2024 - 1.8K bytes - Viewed (0) -
src/cmd/go/internal/workcmd/sync.go
// go work sync package workcmd import ( "cmd/go/internal/base" "cmd/go/internal/gover" "cmd/go/internal/imports" "cmd/go/internal/modload" "cmd/go/internal/toolchain" "context" "golang.org/x/mod/module" ) var cmdSync = &base.Command{ UsageLine: "go work sync", Short: "sync workspace build list to modules", Long: `Sync syncs the workspace's build list back to the
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Jun 03 21:13:11 UTC 2023 - 4.6K bytes - Viewed (0) -
pkg/kube/krt/join.go
return res } func (j *join[T]) Register(f func(o Event[T])) Syncer { return registerHandlerAsBatched[T](j, f) } func (j *join[T]) RegisterBatch(f func(o []Event[T], initialSync bool), runExistingState bool) Syncer { sync := multiSyncer{} for _, c := range j.collections { sync.syncers = append(sync.syncers, c.RegisterBatch(f, runExistingState)) } return sync } // nolint: unused // (not true, its to implement an interface)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 23:33:56 UTC 2024 - 3.3K bytes - Viewed (0) -
src/internal/pkgbits/sync.go
// Private markers (only known to cmd/compile). SyncPrivate SyncFuncExt SyncVarExt SyncTypeExt SyncPragma SyncExprList SyncExprs SyncExpr SyncExprType SyncAssign SyncOp SyncFuncLit SyncCompLit SyncDecl SyncFuncBody SyncOpenScope SyncCloseScope SyncCloseAnotherScope SyncDeclNames SyncDeclName SyncStmts SyncBlockStmt SyncIfStmt
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Aug 04 17:12:28 UTC 2022 - 2.4K bytes - Viewed (0) -
pkg/kube/krt/static.go
return maps.Values(s.vals) } func (s *staticList[T]) Register(f func(o Event[T])) Syncer { return registerHandlerAsBatched(s, f) } func (s *staticList[T]) Synced() Syncer { return alwaysSynced{} } func (s *staticList[T]) RegisterBatch(f func(o []Event[T], initialSync bool), runExistingState bool) Syncer { if runExistingState { f(slices.Map(s.List(), func(e T) Event[T] { return Event[T]{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 23:33:56 UTC 2024 - 2.1K bytes - Viewed (0)