- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for BuildInboundStatPrefix (0.18 sec)
-
pilot/pkg/networking/telemetry/telemetry.go
prefix = strings.ReplaceAll(prefix, servicePortNameStatPattern, port.Name) return prefix } // BuildInboundStatPrefix builds a stat prefix based on the stat pattern and filter chain telemetry data. func BuildInboundStatPrefix(statPattern string, tm FilterChainMetadata, subset string, port uint32, portName string) 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.svc.cluster.local.%DUMMY%", }, } for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { got := BuildInboundStatPrefix(tt.statPattern, tt.tm, tt.subset, tt.port, tt.portName) if got != tt.want { t.Errorf("BuildInboundStatPrefix:: Expected alt statname %s, but got %s", tt.want, got) } }) }
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/listener_inbound.go
statPrefix := fcc.clusterName // If stat name is configured, build the stat prefix from configured pattern. if len(lb.push.Mesh.InboundClusterStatName) != 0 { statPrefix = telemetry.BuildInboundStatPrefix(lb.push.Mesh.InboundClusterStatName, fcc.telemetryMetadata, "", uint32(fcc.port.Port), fcc.port.Name) } tcpProxy := &tcp.TcpProxy{ StatPrefix: statPrefix,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 35.1K bytes - Viewed (0)