Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for DestMatcher (0.14 sec)

  1. tests/integration/security/util/framework.go

    	})
    
    	if !skipVM {
    		m = match.Or(m, match.ServiceName(echo.NamespacedName{
    			Name:      VMSvc,
    			Namespace: ns,
    		}))
    	}
    
    	return m
    }
    
    // DestMatcher matches workload pod B with sidecar injected and VM
    func DestMatcher(ns namespace.Instance, skipVM bool) match.Matcher {
    	m := match.ServiceName(echo.NamespacedName{
    		Name:      BSvc,
    		Namespace: ns,
    	})
    
    	if !skipVM {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 02 21:29:40 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/rest_test.go

    				return nil, false, err
    			}
    		}
    
    		return inPod, false, nil
    	}
    }
    
    func (p *testPatcher) Get(ctx context.Context, name string, options *metav1.GetOptions) (runtime.Object, error) {
    	p.t.Fatal("Unexpected call to testPatcher.Get")
    	return nil, errors.New("Unexpected call to testPatcher.Get")
    }
    
    type testNamer struct {
    	namespace string
    	name      string
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 41.8K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/patch.go

    			updateValidation: rest.AdmissionToValidateObjectUpdateFunc(admit, staticUpdateAttributes, scope),
    			admissionCheck:   mutatingAdmission,
    
    			codec: codec,
    
    			options: options,
    
    			restPatcher: r,
    			name:        name,
    			patchType:   patchType,
    			patchBytes:  patchBytes,
    			userAgent:   req.UserAgent(),
    		}
    
    		result, wasCreated, err := p.patchResource(ctx, scope)
    		if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 28.5K bytes
    - Viewed (0)
  4. pilot/pkg/serviceregistry/kube/controller/controller_test.go

    			},
    		},
    	}
    
    	updateMeshConfig := func(
    		meshConfig *meshconfig.MeshConfig,
    		expectedSvcList []*model.Service,
    		expectedNumSvcEvents int,
    		testMeshWatcher *mesh.TestWatcher,
    		fx *xdsfake.Updater,
    		controller *FakeController,
    	) {
    		// update meshConfig
    		if err := testMeshWatcher.Update(meshConfig, time.Second*5); err != nil {
    			t.Fatalf("%v", err)
    		}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 85K bytes
    - Viewed (0)
Back to top