- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for serviceTargets (0.45 sec)
-
pilot/pkg/networking/core/cluster_builder.go
} // NewClusterBuilder builds an instance of ClusterBuilder. func NewClusterBuilder(proxy *model.Proxy, req *model.PushRequest, cache model.XdsCache) *ClusterBuilder { cb := &ClusterBuilder{ serviceTargets: proxy.ServiceTargets, proxyID: proxy.ID, proxyType: proxy.Type, proxyVersion: proxy.Metadata.IstioVersion, sidecarScope: proxy.SidecarScope,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 31.6K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster.go
type buildClusterOpts struct { mesh *meshconfig.MeshConfig mutable *clusterWrapper policy *networking.TrafficPolicy port *model.Port serviceAccounts []string serviceTargets []model.ServiceTarget // Used for traffic across multiple network clusters // the east-west gateway in a remote cluster will use this value to route // traffic to the appropriate service istioMtlsSni string
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 33K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_inbound.go
ingressPortListSet := sets.New[int]() sidecarScope := lb.node.SidecarScope if sidecarScope.HasIngressListener() { ingressPortListSet = getSidecarIngressPortList(lb.node) } for _, i := range lb.node.ServiceTargets { bindToPort := getBindToPort(networking.CaptureMode_DEFAULT, lb.node) // Skip ports we cannot bind to if !lb.node.CanBindToPort(bindToPort, i.Port.TargetPort) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 35.1K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_test.go
name string direction model.TrafficDirection cluster *cluster.Cluster svcInsts []model.ServiceTarget service *model.Service want *core.Metadata }{ { name: "no cluster", direction: model.TrafficDirectionInbound, cluster: nil, svcInsts: []model.ServiceTarget{ { Service: &model.Service{ Attributes: model.ServiceAttributes{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 108.8K bytes - Viewed (0) -
pilot/pkg/model/gateway.go
if s.GetTls().GetMode() == networking.ServerTLSSettings_AUTO_PASSTHROUGH { hosts.InsertAll(s.Hosts...) } } } } return hosts } func udpSupportedPort(number uint32, instances []ServiceTarget) bool { for _, w := range instances { if int(number) == w.Port.Port && w.Port.Protocol == protocol.UDP { return true } } return false }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 26K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_builder_test.go
t.Run(tc.name, func(t *testing.T) { test.SetForTest(t, &features.EnableAutoSni, tc.enableAutoSni) test.SetForTest(t, &features.VerifyCertAtClient, tc.enableVerifyCertAtClient) targets := []model.ServiceTarget{ { Service: tc.service, Port: model.ServiceInstancePort{ ServicePort: tc.port, TargetPort: 10001, }, }, } var cfg *config.Config
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 110.4K bytes - Viewed (0)