Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for BuildStatPrefix (0.17 sec)

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