- Sort Score
- Result 10 results
- Languages All
Results 181 - 190 of 1,199 for syncAt (0.16 sec)
-
staging/src/k8s.io/apiserver/pkg/server/options/authorizationconfig/metrics/metrics.go
StabilityLevel: metrics.ALPHA, }, []string{"status", "apiserver_id_hash"}, ) ) var registerMetrics sync.Once var hashPool *sync.Pool func RegisterMetrics() { registerMetrics.Do(func() { hashPool = &sync.Pool{ New: func() interface{} { return sha256.New() }, } legacyregistry.MustRegister(authorizationConfigAutomaticReloadsTotal)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 16 13:20:59 UTC 2024 - 3K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/apiserver.go
// to sync makes sure that the lister will be valid before we begin. There may still be races for CRDs added after startup, // but we won't go healthy until we can handle the ones already present. s.GenericAPIServer.AddPostStartHookOrDie("crd-informer-synced", func(context genericapiserver.PostStartHookContext) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 19 14:31:43 UTC 2023 - 11.5K bytes - Viewed (0) -
pkg/controller/nodeipam/ipam/sync/sync_test.go
cidr, _ := cidrset.NewCIDRSet(clusterCIDRRange, 24) tc.fake.logger = logger sync := New(&tc.fake, &tc.fake, &tc.fake, tc.mode, "node1", cidr) doneChan := make(chan struct{}) // Do a single step of the loop. go sync.Loop(logger, doneChan) sync.Update(tc.node) close(sync.opChan) <-doneChan tc.fake.dumpTrace() if !reflect.DeepEqual(tc.fake.events, tc.events) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 05 23:39:52 UTC 2023 - 7.6K bytes - Viewed (0) -
tests/test_dependency_contextmanager.py
yield state["/async"] state["/async"] = "asyncgen completed" def generator_state(state: Dict[str, str] = Depends(get_state)): state["/sync"] = "generator started" yield state["/sync"] state["/sync"] = "generator completed" async def asyncgen_state_try(state: Dict[str, str] = Depends(get_state)): state["/async_raise"] = "asyncgen raise started" try:
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sat Feb 24 23:06:37 UTC 2024 - 11.6K bytes - Viewed (0) -
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r25/TestProgressDaemonErrorsCrossVersionSpec.groovy
given: goodCode() def sync = server.expectAndBlock('sync') when: def result = [] withConnection { ProjectConnection connection -> connection.newBuild().forTasks('test').addProgressListener({ ProgressEvent event -> result << event if (!killed) { sync.waitForAllPendingCalls() sync.releaseAll()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 2.9K bytes - Viewed (0) -
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r25/ContinuousBuildCancellationCrossVersionSpec.groovy
def "client can cancel during execution of a continuous build"() { given: setupCancellationBuild() def sync = server.expectAndBlock('sync') when: runBuild { sync.waitForAllPendingCalls() cancellationTokenSource.cancel() sync.releaseAll() } then: assert buildResult.failure instanceof BuildCancelledException
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 2.9K bytes - Viewed (0) -
pkg/scheduler/metrics/metric_recorder_test.go
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. */ package metrics import ( "sync" "sync/atomic" "testing" ) var _ MetricRecorder = &fakePodsRecorder{} type fakePodsRecorder struct { counter int64 } func (r *fakePodsRecorder) Inc() { atomic.AddInt64(&r.counter, 1) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 00:51:07 UTC 2019 - 2.2K bytes - Viewed (0) -
pkg/controller/disruption/disruption.go
ssLister appsv1listers.StatefulSetLister ssListerSynced cache.InformerSynced // PodDisruptionBudget keys that need to be synced. queue workqueue.TypedRateLimitingInterface[string] recheckQueue workqueue.TypedDelayingInterface[string] // pod keys that need to be synced due to a stale DisruptionTarget condition. stalePodDisruptionQueue workqueue.TypedRateLimitingInterface[string]
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.1K bytes - Viewed (0) -
pilot/pkg/config/memory/monitor.go
func newBufferedMonitor(store model.ConfigStore, bufferSize int, sync bool) Monitor { handlers := make(map[config2.GroupVersionKind][]Handler) for _, s := range store.Schemas().All() { handlers[s.GroupVersionKind()] = make([]Handler, 0) } return &configStoreMonitor{ store: store, handlers: handlers, eventCh: make(chan ConfigEvent, bufferSize), sync: sync, } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 3.3K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/testdata/sayhi.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 20 19:36:41 UTC 2021 - 137 bytes - Viewed (0)