- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 52 for NamespacedName (0.46 sec)
-
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_test_context.go
return false, nil } return true, nil }) } } func (p *PolicyTestContext[P, B, E]) waitForDelete(ctx context.Context, objectGVK schema.GroupVersionKind, name types.NamespacedName) error { srce := p.Source.(*policySource[P, B, E]) return wait.PollUntilContextCancel(ctx, 100*time.Millisecond, true, func(ctx context.Context) (done bool, err error) { switch objectGVK { case p.policyGVK:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 19K bytes - Viewed (0) -
pilot/pkg/model/authentication.go
continue } switch cfg.GroupVersionKind { case gvk.RequestAuthentication: ra := cfg.Spec.(*v1beta1.RequestAuthentication) should := selectionOpts.ShouldAttachPolicy(cfg.GroupVersionKind, cfg.NamespacedName(), ra) if should { configs = append(configs, cfg) } case gvk.PeerAuthentication: selector := labels.Instance(cfg.Spec.(*v1beta1.PeerAuthentication).GetSelector().GetMatchLabels())
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 10.1K bytes - Viewed (0) -
operator/pkg/helmreconciler/reconciler.go
func (h *HelmReconciler) SetStatusBegin() error { isop := &istioV1Alpha1.IstioOperator{} if err := h.getClient().Get(context.TODO(), config.NamespacedName(h.iop), isop); err != nil { if runtime.IsNotRegisteredError(err) { // CRD not yet installed in cluster, nothing to update. return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 22 08:32:23 UTC 2024 - 22K bytes - Viewed (0) -
pkg/webhooks/validation/controller/controller.go
LabelSelector: fmt.Sprintf("%s=%s", label.IoIstioRev.Name, o.Revision), }) c.webhooks.AddEventHandler(controllers.ObjectHandler(c.queue.AddObject)) return c } func (c *Controller) Reconcile(key types.NamespacedName) error { name := key.Name whc := c.webhooks.Get(name, "") scope := scope.WithLabels("webhook", name) // Stop early if webhook is not present, rather than attempting (and failing) to reconcile permanently
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 28 16:52:19 UTC 2024 - 11.3K bytes - Viewed (0) -
pilot/pkg/autoregistration/controller.go
if !features.WorkloadEntryAutoRegistration { return } c.lateRegistrationQueue = controllers.NewQueue("auto-register existing connections", controllers.WithReconciler(func(key kubetypes.NamespacedName) error { log.Debugf("(%s) processing WorkloadGroup add for %s/%s", c.instanceID, key.Namespace, key.Name) // WorkloadGroup doesn't exist anymore, skip this.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 00:00:36 UTC 2024 - 26.4K bytes - Viewed (0) -
tests/integration/telemetry/api/wasmplugin_test.go
args := map[string]any{ "WasmPluginName": pluginName, "TestWasmModuleURL": wasmModuleURL, "WasmPluginVersion": pluginVersion, "TargetAppName": GetTarget().(echo.Instances).NamespacedName().Name, "TargetGatewayName": GetTarget().(echo.Instances).ServiceName() + "-gateway", } if len(imagePullPolicy) != 0 { args["ImagePullPolicy"] = imagePullPolicy }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 14.4K bytes - Viewed (0) -
tests/integration/security/reachability_test.go
// Add the migration app to the full list of services. allServices := apps.Ns1.All.Append(migrationApp.Services()) // Create matchers for the migration app. migration := match.ServiceName(migrationApp.NamespacedName()) notMigration := match.Not(migration) // Call options to be used for tests using the migration app. migrationOpts := []echo.CallOptions{ { Port: echo.Port{ Name: ports.HTTP.Name,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 02 21:29:40 UTC 2024 - 20.6K bytes - Viewed (0) -
tests/integration/security/egress_gateway_origination_test.go
WithDefaultFilters(1, 1). FromMatch(match.And( match.Namespace(apps.Ns1.Namespace), match.NotNaked, match.NotProxylessGRPC)). ToMatch(match.ServiceName(apps.External.All.NamespacedName()))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 15.4K bytes - Viewed (0) -
tests/integration/pilot/gateway_test.go
host: "foo.example.com", }, } testCases = append(testCases, additionalTestCases...) } for _, tc := range testCases { t.NewSubTest(fmt.Sprintf("gateway-connectivity-from-%s", tc.from[0].NamespacedName())).Run(func(t framework.TestContext) { tc.from[0].CallOrFail(t, echo.CallOptions{ Port: echo.Port{ Protocol: protocol.HTTP, ServicePort: 80, }, Scheme: scheme.HTTP,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 17.7K bytes - Viewed (0) -
tests/integration/helm/util.go
ctx.Fatalf("failed to write iop cr file: %v", err) } return overrideValuesFile } var DefaultNamespaceConfig = NewNamespaceConfig() func NewNamespaceConfig(config ...types.NamespacedName) NamespaceConfig { result := make(nsConfig, len(config)) for _, c := range config { result[c.Name] = c.Namespace } return result } type nsConfig map[string]string
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 09 19:04:51 UTC 2024 - 18.7K bytes - Viewed (0)