- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 28 for expectActions (0.2 sec)
-
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/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) -
pkg/controller/controller_utils_test.go
assert.NoError(t, err, "Could not get expectations for rc, exists %v and err %v", exists, err) assert.True(t, exists, "Could not get expectations for rc, exists %v and err %v", exists, err) add, del := podExp.GetExpectations() assert.Equal(t, test.wantPodExpectations[0], add, "Unexpected pod expectations %#v", podExp) assert.Equal(t, test.wantPodExpectations[1], del, "Unexpected pod expectations %#v", podExp)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 39.4K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set.go
} logger.V(4).Info("Deleting", "replicaSet", klog.KObj(rs)) // Delete expectations for the ReplicaSet so if we create a new one with the same name it starts clean rsc.expectations.DeleteExpectations(logger, key) rsc.queue.Add(key) } // When a pod is created, enqueue the replica set that manages it and update its expectations. func (rsc *ReplicaSetController) addPod(logger klog.Logger, obj interface{}) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.2K bytes - Viewed (0) -
pilot/pkg/xds/mesh_network_test.go
networkView []string labels map[string]string proxy *model.Proxy expectations map[string][]string weightedExpectations map[string][]xdstest.LocLbEpInfo } func (w *workload) Expect(target *workload, ips ...string) { if w.expectations == nil { w.expectations = map[string][]string{} } w.expectations[target.clusterName("")] = ips }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 16:59:05 UTC 2024 - 24.6K bytes - Viewed (0) -
security/pkg/nodeagent/sds/sdsservice_test.go
} func (s *TestServer) Verify(resp *discovery.DiscoveryResponse, expectations ...Expectation) *discovery.DiscoveryResponse { s.t.Helper() if len(resp.Resources) != len(expectations) { s.t.Fatalf("expected %d resources, got %d", len(expectations), len(resp.Resources)) } got := xdstest.ExtractTLSSecrets(s.t, resp.Resources) for _, e := range expectations { scrt := got[e.ResourceName] var expectationKey []byte
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jan 17 20:12:58 UTC 2024 - 11.6K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/conversion_test.go
validator := crdvalidation.NewIstioValidator(t) type res struct { name, namespace string allowed bool } cases := []struct { name string config string expectations []res }{ { name: "simple", config: `apiVersion: gateway.networking.k8s.io/v1beta1 kind: ReferenceGrant metadata: name: allow-gateways-to-ref-secrets namespace: default spec:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 20:24:52 UTC 2024 - 34.9K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/operation_generator_test.go
var tests = []struct { name string pvc *v1.PersistentVolumeClaim pv *v1.PersistentVolume recoverFeatureGate bool disableNodeExpansion bool // expectations of test expectedResizeStatus v1.ClaimResourceStatus expectedAllocatedSize resource.Quantity expectResizeCall bool }{ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 16.2K bytes - Viewed (0) -
pkg/controller/servicecidrs/servicecidrs_controller_test.go
// so we skup the errors and only assert on the actions // https://github.com/kubernetes/kubernetes/issues/99953 _ = controller.sync(tCtx, tc.cidrSynced) expectAction(t, client.Actions(), tc.actions) }) } } func makeServiceCIDR(name, primary, secondary string) *networkingapiv1alpha1.ServiceCIDR { serviceCIDR := &networkingapiv1alpha1.ServiceCIDR{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 22K bytes - Viewed (0)