- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 96 for proxyIps (0.13 sec)
-
pilot/pkg/networking/core/cluster_test.go
peerAuthn *authn_beta.PeerAuthentication externalService bool meta *model.NodeMetadata istioVersion *model.IstioVersion proxyIps []string } func (c clusterTest) fillDefaults() clusterTest { if c.proxyIps == nil { c.proxyIps = []string{"6.6.6.6", "::1"} } if c.istioVersion == nil { c.istioVersion = model.MaxIstioVersion } if c.meta == nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 108.8K bytes - Viewed (0) -
pkg/proxy/kubemark/hollow_proxy.go
v1core "k8s.io/client-go/kubernetes/typed/core/v1" "k8s.io/client-go/tools/events" proxyapp "k8s.io/kubernetes/cmd/kube-proxy/app" proxyconfigapi "k8s.io/kubernetes/pkg/proxy/apis/config" proxyconfig "k8s.io/kubernetes/pkg/proxy/config" "k8s.io/utils/ptr" ) type HollowProxy struct { ProxyServer *proxyapp.ProxyServer } type FakeProxier struct { proxyconfig.NoopNodeHandler }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 2.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/util_test.go
svc.Annotations = map[string]string{ "traffic.istio.io/nodeSelector": nodeSelector, } } return svc } func hasProxyIP(addresses []v1.EndpointAddress, proxyIP string) bool { for _, addr := range addresses { if addr.IP == proxyIP { return true } } return false
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 21 20:45:12 UTC 2023 - 5K bytes - Viewed (0) -
pilot/pkg/serviceregistry/util/workloadinstances/util.go
// GetInstanceForProxy returns a workload instance that // corresponds to a given proxy, if any. func GetInstanceForProxy(index Index, proxy *model.Proxy, proxyIP string) *model.WorkloadInstance { if !slices.Contains(proxy.IPAddresses, proxyIP) { return nil } instances := index.GetByIP(proxyIP) // list is ordered by namespace/name if len(instances) == 0 { return nil } if len(instances) == 1 { // dominant use case
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 24 17:36:41 UTC 2023 - 2.8K bytes - Viewed (0) -
pilot/pkg/model/push_context_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 21 17:42:54 UTC 2024 - 95.3K bytes - Viewed (0) -
cmd/admin-handlers-pools.go
host := env.Get("_MINIO_DECOM_ENDPOINT_HOST", defaultEndPoint.Host) if host == "" { return } for nodeIdx, proxyEp := range globalProxyEndpoints { if proxyEp.Endpoint.Host == host && !proxyEp.IsLocal { if proxyRequestByNodeIndex(ctx, w, r, nodeIdx) { return true } } } return
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 10.9K bytes - Viewed (0) -
pkg/registry/core/service/proxy.go
proxyOpts, ok := opts.(*api.ServiceProxyOptions) if !ok { return nil, fmt.Errorf("Invalid options object: %#v", opts) } location, transport, err := r.Redirector.ResourceLocation(ctx, id) if err != nil { return nil, err } location.Path = net.JoinPreservingTrailingSlash(location.Path, proxyOpts.Path)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 19 13:59:13 UTC 2022 - 2.9K bytes - Viewed (0) -
pkg/kube/inject/testdata/inject/resource_annotations.yaml
apiVersion: apps/v1 kind: Deployment metadata: name: resource spec: replicas: 7 selector: matchLabels: app: resource template: metadata: annotations: sidecar.istio.io/proxyCPU: "100m" sidecar.istio.io/proxyCPULimit: "1000m" sidecar.istio.io/proxyMemory: "1Gi" sidecar.istio.io/proxyMemoryLimit: "2Gi" labels: app: resource spec: containers:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 18 21:43:45 UTC 2020 - 578 bytes - Viewed (0) -
cmd/genkubedocs/gen_kube_docs.go
"os" "github.com/spf13/cobra/doc" "github.com/spf13/pflag" "k8s.io/kubernetes/cmd/genutils" apiservapp "k8s.io/kubernetes/cmd/kube-apiserver/app" cmapp "k8s.io/kubernetes/cmd/kube-controller-manager/app" proxyapp "k8s.io/kubernetes/cmd/kube-proxy/app" schapp "k8s.io/kubernetes/cmd/kube-scheduler/app" kubeadmapp "k8s.io/kubernetes/cmd/kubeadm/app/cmd" kubeletapp "k8s.io/kubernetes/cmd/kubelet/app" ) func main() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 01 05:59:41 UTC 2022 - 2.8K bytes - Viewed (0) -
pkg/registry/core/node/rest/proxy.go
proxyOpts, ok := opts.(*api.NodeProxyOptions) if !ok { return nil, fmt.Errorf("Invalid options object: %#v", opts) } location, transport, err := node.ResourceLocation(r.Store, r.Connection, r.ProxyTransport, ctx, id) if err != nil { return nil, err } location.Path = net.JoinPreservingTrailingSlash(location.Path, proxyOpts.Path)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 19 13:59:13 UTC 2022 - 3.1K bytes - Viewed (0)