Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for wle (0.12 sec)

  1. pilot/pkg/serviceregistry/util/workloadinstances/index_test.go

    			ServiceAccount: spiffe.MustGenSpiffeURIForTrustDomain("cluster.local", selector.Name, "default"),
    			TLSMode:        model.IstioMutualTLSModeLabel,
    		},
    	}
    
    	wi3 := &model.WorkloadInstance{
    		Name:      "another-name",
    		Namespace: "dns-selector",
    		Endpoint: &model.IstioEndpoint{
    			Address:        "2.2.2.2",
    			Labels:         map[string]string{"app": "dns-wle"},
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 5K bytes
    - Viewed (0)
  2. pilot/pkg/serviceregistry/serviceentry/util.go

    )
    
    func getWorkloadServiceEntries(ses []config.Config, wle *networking.WorkloadEntry) map[types.NamespacedName]*config.Config {
    	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
    }
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 02:03:58 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  3. pilot/pkg/autoregistration/internal/health/controller.go

    	"istio.io/istio/pilot/pkg/model"
    	"istio.io/istio/pilot/pkg/model/status"
    	"istio.io/istio/pkg/kube/controllers"
    	istiolog "istio.io/istio/pkg/log"
    )
    
    var log = istiolog.RegisterScope("wle", "wle controller debugging")
    
    type HealthEvent struct {
    	// whether or not the agent thought the target is healthy
    	Healthy bool `json:"healthy,omitempty"`
    	// error message propagated
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Sep 19 20:41:55 UTC 2023
    - 3.4K bytes
    - Viewed (0)
  4. pkg/kube/inject/testdata/inject/job.yaml.injected

            service.istio.io/canonical-name: pi
            service.istio.io/canonical-revision: latest
          name: pi
        spec:
          containers:
          - command:
            - perl
            - -Mbignum=bpi
            - -wle
            - print bpi(2000)
            image: perl
            name: pi
            resources: {}
          - args:
            - proxy
            - sidecar
            - --domain
            - $(POD_NAMESPACE).svc.cluster.local
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Feb 27 16:55:16 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  5. pilot/pkg/serviceregistry/serviceentry/store.go

    	"k8s.io/apimachinery/pkg/types"
    
    	"istio.io/istio/pilot/pkg/model"
    	"istio.io/istio/pkg/util/sets"
    )
    
    type hostPort struct {
    	host instancesKey
    	port int
    }
    
    // stores all the service instances from SE, WLE and pods
    type serviceInstancesStore struct {
    	ip2instance map[string][]*model.ServiceInstance
    	// service instances by hostname -> config
    	instances map[instancesKey]map[configKeyWithParent][]*model.ServiceInstance
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  6. pilot/pkg/serviceregistry/serviceentry/store_test.go

    		makeInstance(dnsSelector, "1.1.1.1", 444, dnsSelector.Spec.(*networking.ServiceEntry).Ports[0], nil, PlainText),
    	}
    	cKey := configKey{
    		namespace: "default",
    		name:      "test-wle",
    	}
    	cpKey := configKeyWithParent{configKey: cKey, parent: config.NamespacedName(selector)}
    	store.addInstances(cpKey, instances)
    
    	// 1. test getByIP
    	gotInstances := store.getByIP("1.1.1.1")
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 8.1K bytes
    - Viewed (0)
Back to top