Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for BuildInboundStatPrefix (0.18 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top