- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for TrafficDirection (1.34 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/networking/core/listener.go
Address: util.BuildAddress(le.bind.Primary(), uint32(le.servicePort.Port)), AdditionalAddresses: util.BuildAdditionalAddresses(le.bind.Extra(), uint32(le.servicePort.Port)), TrafficDirection: core.TrafficDirection_OUTBOUND, ContinueOnListenerFiltersTimeout: true, } if builder.node.Metadata.OutboundListenerExactBalance {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 04:44:06 UTC 2024 - 55.1K bytes - Viewed (0) -
pilot/pkg/networking/core/envoyfilter/listener_patch_test.go
}, }, }, } sidecarVirtualInboundIn := []*listener.Listener{ { Name: model.VirtualInboundListenerName, UseOriginalDst: istio_proto.BoolTrue, TrafficDirection: core.TrafficDirection_INBOUND, Address: &core.Address{ Address: &core.Address_SocketAddress{ SocketAddress: &core.SocketAddress{ PortSpecifier: &core.SocketAddress_PortValue{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 21 17:42:54 UTC 2024 - 70.1K 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)