- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for NewDefaultManager (0.17 sec)
-
staging/src/k8s.io/apiserver/pkg/storageversion/manager.go
managedStatus map[schema.GroupResource]*updateStatus } type updateStatus struct { done bool lastErr error } // NewDefaultManager creates a new defaultManager. func NewDefaultManager() Manager { s := &defaultManager{} s.completed.Store(false) s.managedResourceInfos = make(map[*ResourceInfo]struct{}) s.managedStatus = make(map[schema.GroupResource]*updateStatus)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 14 17:47:19 UTC 2023 - 10.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/peerproxy/peerproxy_handler_test.go
TLS: transport.TLSConfig{ Insecure: false, }} proxyRoundTripper, err := transport.New(clientConfig) if err != nil { return nil, err } ppI := NewPeerProxyHandler(informerFactory, storageversion.NewDefaultManager(), proxyRoundTripper, id, reconciler, s) if testDataExists(svdata.gvr) { ppI.addToStorageVersionMap(svdata.gvr, svdata.serverId) } return ppI, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 10.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/config.go
StorageObjectCountTracker: flowcontrolrequest.NewStorageObjectCountTracker(), ShutdownWatchTerminationGracePeriod: time.Duration(0), APIServerID: id, StorageVersionManager: storageversion.NewDefaultManager(), TracerProvider: tracing.NewNoopTracerProvider(), } } // NewRecommendedConfig returns a RecommendedConfig struct with the default values
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 47.7K bytes - Viewed (0)