Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 19 of 19 for WorkloadSelector (2.92 sec)

  1. pilot/pkg/serviceregistry/serviceentry/util.go

    	out := make(map[types.NamespacedName]*config.Config)
    	for i, cfg := range ses {
    		se := cfg.Spec.(*networking.ServiceEntry)
    		if se.WorkloadSelector != nil && labels.Instance(se.WorkloadSelector.Labels).Match(wle.Labels) {
    			out[cfg.NamespacedName()] = &ses[i]
    		}
    	}
    
    	return out
    }
    
    // returns a set of objects that are in `old` but not in `curr`
    // For example:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 02:03:58 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  2. pkg/config/analysis/analyzers/testdata/destinationrule-simple-destination-credentialname-selector.yaml

    apiVersion: networking.istio.io/v1alpha3
    kind: DestinationRule
    metadata:
      name: db-tls
    spec:
      host: mydbserver.prod.svc.cluster.local
      trafficPolicy:
        tls:
          mode: SIMPLE
          credentialName: db-credential
      workloadSelector:
          matchLabels:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 07:22:31 UTC 2024
    - 271 bytes
    - Viewed (0)
  3. pilot/pkg/serviceregistry/util/workloadinstances/index_test.go

    		Hosts: []string{"selector.com"},
    		Ports: []*networking.ServicePort{
    			{Number: 444, Name: "tcp-444", Protocol: "tcp"},
    			{Number: 445, Name: "http-445", Protocol: "http"},
    		},
    		WorkloadSelector: &networking.WorkloadSelector{
    			Labels: map[string]string{"app": "wle"},
    		},
    		Resolution: networking.ServiceEntry_STATIC,
    	},
    }
    
    func TestIndex(t *testing.T) {
    	// Setup a couple of workload instances for test
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 5K bytes
    - Viewed (0)
  4. pkg/kube/krt/join_test.go

    	})
    
    	se := &istioclient.ServiceEntry{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "svc-entry",
    			Namespace: "namespace",
    		},
    		Spec: istio.ServiceEntry{WorkloadSelector: &istio.WorkloadSelector{Labels: map[string]string{"app": "foo"}}},
    	}
    	sec.Create(se)
    	assert.EventuallyEqual(t, fetch, []SimpleEndpoint{
    		{pod.Name, se.Name, pod.Namespace, pod.Status.PodIP},
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 09 19:55:53 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  5. samples/ratelimit/local-rate-limit-service.yaml

    apiVersion: networking.istio.io/v1alpha3
    kind: EnvoyFilter
    metadata:
      name: filter-local-ratelimit-svc
      namespace: istio-system
    spec:
      workloadSelector:
        labels:
          app: productpage
      configPatches:
        - applyTo: HTTP_FILTER
          match:
            context: SIDECAR_INBOUND
            listener:
              filterChain:
                filter:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Aug 31 08:22:09 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  6. tests/integration/pilot/cross_revision_test.go

    			// Allow all namespaces so we do not hit passthrough cluster
    			t.ConfigIstio().YAML(apps.Namespace.Name(), `apiVersion: networking.istio.io/v1alpha3
    kind: Sidecar
    metadata:
      name: allow-cross-namespaces
    spec:
      workloadSelector:
        labels:
          app: a
      egress:
      - hosts:
        - "*/*"`).ApplyOrFail(t)
    			// create an echo instance in each revisioned namespace, all these echo
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 08 22:02:59 UTC 2024
    - 3K bytes
    - Viewed (0)
  7. pilot/pkg/model/policyattachment.go

    type TargetablePolicy interface {
    	GetTargetRef() *v1beta1.PolicyTargetReference
    	GetTargetRefs() []*v1beta1.PolicyTargetReference
    	GetSelector() *v1beta1.WorkloadSelector
    }
    
    // WorkloadPolicyMatcher performs policy selection either using targetRef or label selectors.
    // Label selection uses the workload labels.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 22:20:44 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  8. tests/integration/pilot/workloadentry_test.go

      - 240.240.240.240
      hosts: 
      - serviceentry.mesh.global
      ports:
      - number: 80
        targetPort: 18080
        name: http
        protocol: HTTP
      resolution: STATIC
      location: MESH_INTERNAL
      workloadSelector:
        labels:
          app: b
          topology.istio.io/cluster: %s
    `
    
    			exposeServices := `
    apiVersion: networking.istio.io/v1alpha3
    kind: Gateway
    metadata:
      name: cross-network-gateway
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 08 22:02:59 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  9. pkg/kube/krt/internal.go

    	}
    
    	labelsField := specField.FieldByName("Selector")
    	if !labelsField.IsValid() {
    		panic(fmt.Sprintf("obj %T has no Selector", a))
    	}
    
    	switch s := labelsField.Interface().(type) {
    	case *v1beta1.WorkloadSelector:
    		return s.GetMatchLabels()
    	case map[string]string:
    		return s
    	default:
    		panic(fmt.Sprintf("obj %T has unknown Selector", s))
    	}
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 10 23:33:56 UTC 2024
    - 5.6K bytes
    - Viewed (0)
Back to top