- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 81 for expectActions (1.08 sec)
-
pkg/controller/certificates/rootcacertpublisher/publisher_test.go
AddedNamespace *v1.Namespace UpdatedNamespace *v1.Namespace DeletedConfigMap *v1.ConfigMap UpdatedConfigMap *v1.ConfigMap ExpectActions []action }{ "create new namespace": { AddedNamespace: newNs, ExpectActions: []action{{verb: "create", name: RootCACertConfigMapName}}, }, "delete other configmap": { ExistingConfigMaps: []*v1.ConfigMap{otherConfigMap, caConfigMap},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:16 UTC 2023 - 7.9K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller_test.go
t.Errorf("Expected 2 more actions, got %d", len(client.Actions())-numActionsBefore) } // only 2 slices should match, 2 should be deleted, 1 should be updated as a placeholder expectAction(t, client.Actions(), numActionsBefore, "update", "endpointslices") expectAction(t, client.Actions(), numActionsBefore+1, "delete", "endpointslices") // ensure cache mutation has not occurred cmc.Check(t) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 65.5K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/BlockingHttpServer.java
List<ResourceExpectation> expectations = new ArrayList<>(); for (ExpectedRequest call : expectedCalls) { expectations.add((ResourceExpectation) call); } addNonBlockingHandler(expectations); } private void addNonBlockingHandler(final Collection<? extends ResourceExpectation> expectations) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 21.7K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/sftp/SFTPServer.groovy
return new URI("sftp://${hostAddress}:${port}") } void allowAll() { expectations << new SftpAllowAll() } void allowInit() { expectations << new SftpAllow(SftpConstants.SSH_FXP_INIT) } void expectLstat(String path) { expectations << new SftpExpectOnePath(SftpConstants.SSH_FXP_LSTAT, "LSTAT", path) }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 17.1K bytes - Viewed (0) -
pkg/controller/job/tracking_utils_test.go
firstRound: []string{"w"}, secondRound: []string{"a"}, }, } expectations := newUIDTrackingExpectations() // Insert first round of keys in parallel. var wg sync.WaitGroup wg.Add(len(tracks)) errs := make([]error, len(tracks)) for i := range tracks { track := tracks[i] go func(errID int) { errs[errID] = expectations.expectFinalizersRemoved(logger, track.job, track.firstRound) wg.Done() }(i)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 14 05:40:02 UTC 2023 - 5.9K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/ExpectAllRequestsThenReleaseAll.java
ExpectAllRequestsThenReleaseAll(Lock lock, int testId, Duration timeout, WaitPrecondition previous, Collection<? extends ResourceExpectation> expectations, Executor executor) { super(lock, testId, timeout, expectations.size(), previous, expectations, executor); } @Override void doReleaseAction(BlockingHttpServer.BlockingHandler handler, int yetToBeReceived) { handler.releaseAll(); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 1.3K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/ServerWithExpectations.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 1.9K bytes - Viewed (0) -
pkg/controller/controller_utils.go
if exp.Fulfilled() { logger.V(4).Info("Controller expectations fulfilled", "expectations", exp) return true } else if exp.isExpired() { logger.V(4).Info("Controller expectations expired", "expectations", exp) return true } else { logger.V(4).Info("Controller still waiting on expectations", "expectations", exp) return false } } else if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 12 15:34:44 UTC 2024 - 47.6K bytes - Viewed (0) -
platforms/software/dependency-management/src/integTest/groovy/org/gradle/integtests/resolve/derived/MultiProjectVariantResolutionIntegrationTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 10 21:10:11 UTC 2023 - 10.7K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set_test.go
if err != nil { t.Errorf("Couldn't get key for object %#v: %v", rsSpec, err) } // Lowering expectations should lead to a sync that creates a replica, however the // fakePodControl error will prevent this, leaving expectations at 0, 0 manager.expectations.CreationObserved(logger, rsKey) rsSpec.Status.Replicas = 1 rsSpec.Status.ReadyReplicas = 1 rsSpec.Status.AvailableReplicas = 1
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 69.2K bytes - Viewed (0)