- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for TrafficDirection (0.24 sec)
-
pilot/pkg/model/service.go
type PortList []*Port // TrafficDirection defines whether traffic exists a service instance or enters a service instance type TrafficDirection string const ( // TrafficDirectionInbound indicates inbound traffic TrafficDirectionInbound TrafficDirection = "inbound" // TrafficDirectionInboundVIP indicates inbound traffic for vip TrafficDirectionInboundVIP TrafficDirection = "inbound-vip"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 02:03:58 UTC 2024 - 46.3K bytes - Viewed (0) -
pilot/pkg/model/service_test.go
ParseSubsetKey("outbound|80|v1|example.com") ParseSubsetKey("outbound_.8080_.v1_.foo.example.org") } } func TestParseSubsetKey(t *testing.T) { tests := []struct { input string direction TrafficDirection subsetName string hostname host.Name port int }{ {"outbound|80|v1|example.com", TrafficDirectionOutbound, "v1", "example.com", 80}, {"", "", "", "", 0}, {"|||", "", "", "", 0},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 20:38:02 UTC 2024 - 13.9K bytes - Viewed (0) -
pilot/pkg/xds/endpoints/endpoint_builder.go
subsetName string subsetLabels labels.Instance hostname host.Name port int push *model.PushContext proxy *model.Proxy dir model.TrafficDirection mtlsChecker *mtlsChecker } func NewEndpointBuilder(clusterName string, proxy *model.Proxy, push *model.PushContext) EndpointBuilder { dir, subsetName, hostname, port := model.ParseSubsetKey(clusterName)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 28 02:18:19 UTC 2024 - 26.1K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_inbound.go
l := &listener.Listener{ Name: MainInternalName, ListenerSpecifier: &listener.Listener_InternalListener{InternalListener: &listener.Listener_InternalListenerConfig{}}, TrafficDirection: core.TrafficDirection_INBOUND, ContinueOnListenerFiltersTimeout: true, } // Flush authz cache since we need filter state for the principal. oldBuilder := lb.authzBuilder
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_builder.go
// It is used for building both inbound and outbound cluster. func (cb *ClusterBuilder) buildCluster(name string, discoveryType cluster.Cluster_DiscoveryType, localityLbEndpoints []*endpoint.LocalityLbEndpoints, direction model.TrafficDirection, port *model.Port, service *model.Service, inboundServices []model.ServiceTarget, subset string, ) *clusterWrapper { c := &cluster.Cluster{ Name: name,
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/listener_builder.go
Address: util.BuildAddress(actualWildcards[0], uint32(lb.push.Mesh.ProxyListenPort)), Transparent: isTransparentProxy, UseOriginalDst: proto.BoolTrue, FilterChains: filterChains, TrafficDirection: core.TrafficDirection_OUTBOUND, } // add extra addresses for the listener if features.EnableDualStack && len(actualWildcards) > 1 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 04:44:06 UTC 2024 - 17.9K bytes - Viewed (0) -
pilot/pkg/model/sidecar.go
} else { sc.configDependencies.InsertAll(dependencies...) } } // DestinationRule returns a destinationrule for a svc. func (sc *SidecarScope) DestinationRule(direction TrafficDirection, proxy *Proxy, svc host.Name) *ConsolidatedDestRule { destinationRules := sc.destinationRules[svc] var catchAllDr *ConsolidatedDestRule for _, destRule := range destinationRules {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 20:32:23 UTC 2024 - 38.4K bytes - Viewed (0) -
istioctl/pkg/proxyconfig/proxyconfig.go
} if err != nil { return err } filter := configdump.ClusterFilter{ FQDN: host.Name(fqdn), Port: port, Subset: subset, Direction: model.TrafficDirection(direction), } switch outputFormat { case summaryOutput: return configWriter.PrintClusterSummary(filter) case jsonOutput, yamlOutput:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 03:28:36 UTC 2024 - 48K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_waypoint.go
xdsfilters.OriginalDestination, // TODO: This may affect the data path due to the server-first protocols triggering a time-out. Need exception filter. xdsfilters.HTTPInspector, }, TrafficDirection: core.TrafficDirection_INBOUND, FilterChains: chains, FilterChainMatcher: &matcher.Matcher{ MatcherType: &matcher.Matcher_MatcherTree_{ MatcherTree: &matcher.Matcher_MatcherTree{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 27.6K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster.go
// the east-west gateway in a remote cluster will use this value to route // traffic to the appropriate service istioMtlsSni string clusterMode ClusterMode direction model.TrafficDirection meshExternal bool serviceMTLSMode model.MutualTLSMode // Indicates the service registry of the cluster being built. serviceRegistry provider.ID // Indicates if the destinationRule has a workloadSelector
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 33K bytes - Viewed (0)