}

	if fake.CommandCalls != len(expecteds) {
		allErrs = append(allErrs,
			fmt.Errorf("unexpected command calls in scenario: expected %d, saw: %d", len(expecteds), fake.CommandCalls))
	}
	var expectedCmds [][]string
	for _, expected := range expecteds {
		expectedCmds = append(expectedCmds, expected.cmd)
	}
	if !reflect.DeepEqual(expectedCmds, fcmd.CombinedOutputLog) {
		allErrs = append(allErrs,

    observedGeneration: 3
    reason: reasonValue
    status: statusValue
    type: typeValue
  currentHealthy: 4
  desiredHealthy: 5
  disruptedPods:
    disruptedPodsKey: null
  disruptionsAllowed: 3
  expectedPods: 6

		t.Fatalf("failed to generate JWT: %v", err)
	}

	tests := map[string]struct {
		token      string
		expectErr  bool
		expectedID string
	}{
		"No bearer token": {
			expectErr: true,
		},
		"Valid token": {
			token:      token,
			expectErr:  false,
			expectedID: spiffe.MustGenSpiffeURIForTrustDomain("baz.svc.id.goog", "bar", "foo"),
		},
		"Expired token": {
			token:     expiredToken,

    observedGeneration: 3
    reason: reasonValue
    status: statusValue
    type: typeValue
  currentHealthy: 4
  desiredHealthy: 5
  disruptedPods:
    disruptedPodsKey: null
  disruptionsAllowed: 3
  expectedPods: 6

  },
  "status": {
    "observedGeneration": 1,
    "disruptedPods": {
      "disruptedPodsKey": null
    },
    "disruptionsAllowed": 3,
    "currentHealthy": 4,
    "desiredHealthy": 5,
    "expectedPods": 6,
    "conditions": [
      {
        "type": "typeValue",
        "status": "statusValue",
        "observedGeneration": 3,
        "lastTransitionTime": "2004-01-01T01:01:01Z",
        "reason": "reasonValue",

		t.Fatalf("service IP incorrect => %q, want %q", ips[0], ip)
	}

	actualIPs := service.ClusterVIPs.GetAddressesFor(clusterID)
	expectedIPs := []string{ip}
	if !reflect.DeepEqual(actualIPs, expectedIPs) {
		t.Fatalf("service IPs incorrect => %q, want %q", actualIPs, expectedIPs)
	}

	if !reflect.DeepEqual(service.Attributes.LabelSelectors, localSvc.Spec.Selector) {

		setGws(c.NetworkGateways())
		notifyCh <- struct{}{}
	})
	expectGateways := func(t *testing.T, expectedGws int) {
		// wait for a notification
		assert.ChannelHasItem(t, notifyCh)
		if n := len(getGws()); n != expectedGws {
			t.Errorf("expected %d gateways but got %d", expectedGws, n)
		}
	}

	t.Run("add meshnetworks", func(t *testing.T) {
		addMeshNetworksFromRegistryGateway(t, c, meshNetworks)

    }

    private static void verifyExpectedOps(List<BuildOperationRecord> ops, List<ExpectedOperation> expectedOps) {
        assert ops.size() == expectedOps.size()
        // no guarantees about listener execution order
        assert ops.find { op ->

)

func verifyListPVs(t *testing.T, cache *PVAssumeCache, expectedPVs map[string]*v1.PersistentVolume, storageClassName string) {
	pvList := cache.ListPVs(storageClassName)
	if len(pvList) != len(expectedPVs) {
		t.Errorf("ListPVs() returned %v PVs, expected %v", len(pvList), len(expectedPVs))
	}
	for _, pv := range pvList {
		expectedPV, ok := expectedPVs[pv.Name]
		if !ok {

	DesiredHealthy int32 `json:"desiredHealthy" protobuf:"varint,5,opt,name=desiredHealthy"`

	// total number of pods counted by this disruption budget
	ExpectedPods int32 `json:"expectedPods" protobuf:"varint,6,opt,name=expectedPods"`

	// Conditions contain conditions for PDB. The disruption controller sets the
	// DisruptionAllowed condition. The following are known values for the reason field