- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 163 for NamespacedName (0.18 sec)
-
tests/integration/security/util/framework.go
func SourceMatcher(ns namespace.Instance, skipVM bool) match.Matcher { m := match.ServiceName(echo.NamespacedName{ Name: ASvc, Namespace: ns, }) if !skipVM { m = match.Or(m, match.ServiceName(echo.NamespacedName{ Name: VMSvc, Namespace: ns, })) } return m }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 02 21:29:40 UTC 2024 - 8.4K bytes - Viewed (0) -
tests/integration/security/authz_test.go
Apply() newTrafficTest(t, fromAndTo). FromMatch(fromMatch). ToMatch(toMatch). Run(func(t framework.TestContext, from echo.Instance, to echo.Target) { allow := allowValue(from.NamespacedName() == allowed.NamespacedName()) cases := []struct { ports []echo.Port path string allow allowValue }{ { ports: []echo.Port{ports.GRPC, ports.TCP}, allow: allow,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 23:36:51 UTC 2024 - 50.1K bytes - Viewed (0) -
pkg/proxy/nftables/proxier_test.go
spn: proxy.ServicePortName{ NamespacedName: types.NamespacedName{ Namespace: "testing", Name: "service", }, Port: "http", }, protocol: "tcp", expected: "P4ZYZVCF-testing/service/tcp/http", }, { name: "different port, different hash", spn: proxy.ServicePortName{ NamespacedName: types.NamespacedName{ Namespace: "testing",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 01:31:57 UTC 2024 - 173.5K bytes - Viewed (0) -
pkg/kube/krt/bench_test.go
events <- fmt.Sprintf(e.Latest().Name, e.Event) }) } type legacy struct { pods kclient.Client[*v1.Pod] services kclient.Client[*v1.Service] queue controllers.Queue workloads map[types.NamespacedName]*Workload handler func(event krt.Event[Workload]) } func getPodServices(allServices []*v1.Service, pod *v1.Pod) []*v1.Service { var services []*v1.Service for _, service := range allServices {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 09 19:55:53 UTC 2024 - 7K bytes - Viewed (0) -
security/pkg/server/ca/node_auth_test.go
TrustDomain: "cluster.local", Namespace: p.namespace, ServiceAccount: p.account, }.String() } func TestSingleClusterNodeAuthorization(t *testing.T) { allowZtunnel := map[types.NamespacedName]struct{}{ {Name: "ztunnel", Namespace: "istio-system"}: {}, } ztunnelCaller := security.KubernetesInfo{ PodName: "ztunnel-a", PodNamespace: "istio-system", PodUID: "12345",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 10.5K bytes - Viewed (0) -
pilot/pkg/networking/apigen/apigen.go
// Right now model.Config is not a proto - until we change it, mcp.Resource. // This also helps migrating MCP users. b, err := config.PilotConfigToResource(&c) if err != nil { log.WithLabels("resource", c.NamespacedName()).Warnf("resource error: %v", err) continue } resp = append(resp, &discovery.Resource{ Name: c.Namespace + "/" + c.Name, Resource: protoconv.MessageToAny(b), }) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Oct 05 19:01:38 UTC 2023 - 5K bytes - Viewed (0) -
pilot/pkg/model/policyattachment.go
targetRefs = []*v1beta1.PolicyTargetReference{p.GetTargetRef()} } return targetRefs } func (p WorkloadPolicyMatcher) ShouldAttachPolicy(kind config.GroupVersionKind, policyName types.NamespacedName, policy TargetablePolicy) bool { gatewayName, isGatewayAPI := workloadGatewayName(p.WorkloadLabels) targetRefs := GetTargetRefs(policy) // non-gateway: use selector if !isGatewayAPI {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 4.9K bytes - Viewed (0) -
pilot/pkg/config/aggregate/config.go
// Used to remove duplicated config configMap := sets.NewWithLength[types.NamespacedName](configCnt) for _, curConfigs := range storeConfigs { configs = append(configs, curConfigs...) } configs = slices.FilterInPlace[config.Config](configs, func(cfg config.Config) bool { return !configMap.InsertContains(cfg.NamespacedName()) }) return configs }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Dec 26 01:14:27 UTC 2023 - 5.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_source_test.go
func (fb *FakeBinding) GetName() string { return fb.Name } func (fb *FakeBinding) GetNamespace() string { return fb.Namespace } func (fb *FakeBinding) GetPolicyName() types.NamespacedName { return types.NamespacedName{ Name: fb.PolicyName, } } func (fb *FakeBinding) GetMatchResources() *v1.MatchResources { return nil } func (fb *FakeBinding) GetParamRef() *v1.ParamRef { return nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 6.2K bytes - Viewed (0) -
istioctl/pkg/ztunnelconfig/ztunnelconfig.go
func PodOnNodeFromDaemonset(node string, name, namespace string, client kube.Client) (types.NamespacedName, error) { ds, err := client.Kube().AppsV1().DaemonSets(namespace).Get(context.Background(), name, metav1.GetOptions{}) if err != nil { return types.NamespacedName{}, err } selector := ds.Spec.Selector if selector == nil { return types.NamespacedName{}, fmt.Errorf("selector is required") } sel := selector.MatchLabels
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 20:18:34 UTC 2024 - 22K bytes - Viewed (0)