- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for BuildStatPrefix (0.19 sec)
-
pilot/pkg/networking/telemetry/telemetry.go
serviceTargetPortStatPattern = "%TARGET_PORT%" servicePortNameStatPattern = "%SERVICE_PORT_NAME%" subsetNameStatPattern = "%SUBSET_NAME%" ) // BuildStatPrefix builds a stat prefix based on the stat pattern. func BuildStatPrefix(statPattern string, host string, subset string, port *model.Port, targetPort int, attributes *model.ServiceAttributes) string {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jul 25 02:38:43 UTC 2023 - 4.3K bytes - Viewed (0) -
pilot/pkg/networking/telemetry/telemetry_test.go
}, "reviews.default_grpc-svc_9443", }, } for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { got := BuildStatPrefix(tt.statPattern, tt.host, tt.subsetName, tt.port, tt.targetPort, tt.attributes) if got != tt.want { t.Errorf("BuildStatPrefix:: Expected alt statname %s, but got %s", tt.want, got) } }) } } func TestTraceOperation(t *testing.T) { tests := []struct {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jul 25 02:38:43 UTC 2023 - 12.1K bytes - Viewed (0) -
pilot/pkg/networking/core/tls.go
statPrefix := clusterName // If stat name is configured, use it to build the stat prefix. if len(push.Mesh.OutboundClusterStatName) != 0 { statPrefix = telemetry.BuildStatPrefix(push.Mesh.OutboundClusterStatName, string(service.Hostname), "", &model.Port{Port: port}, 0, &service.Attributes) } // Use the hostname as the SNI value if and only: // 1) if the destination is a CIDR;
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 17:09:02 UTC 2024 - 14.7K bytes - Viewed (0) -
pilot/pkg/networking/core/networkfilter.go
statPrefix := clusterName // If stat name is configured, build the stat prefix from configured pattern. if len(push.Mesh.OutboundClusterStatName) != 0 && service != nil { statPrefix = telemetry.BuildStatPrefix(push.Mesh.OutboundClusterStatName, routes[0].Destination.Host, routes[0].Destination.Subset, port, 0, &service.Attributes) } return lb.buildOutboundNetworkFiltersWithSingleDestination(
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 13.7K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_builder.go
if direction == model.TrafficDirectionOutbound { // If stat name is configured, build the alternate stats name. if len(cb.req.Push.Mesh.OutboundClusterStatName) != 0 { ec.cluster.AltStatName = telemetry.BuildStatPrefix(cb.req.Push.Mesh.OutboundClusterStatName, string(service.Hostname), subset, port, 0, &service.Attributes) } } return ec }
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/gateway.go
clusterName := model.BuildDNSSrvSubsetKey(model.TrafficDirectionOutbound, "", service.Hostname, port.Port) statPrefix := clusterName if len(push.Mesh.OutboundClusterStatName) != 0 { statPrefix = telemetry.BuildStatPrefix(push.Mesh.OutboundClusterStatName, string(service.Hostname), "", port, 0, &service.Attributes) } destinationRule := CastDestinationRule(proxy.SidecarScope.DestinationRule(
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 04:44:06 UTC 2024 - 46.4K bytes - Viewed (0)