Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for GetMetricType (0.27 sec)

  1. pilot/pkg/xds/v3/model.go

    func GetShortType(typeURL string) string {
    	return model.GetShortType(typeURL)
    }
    
    // GetMetricType returns the form of a type reported for metrics
    func GetMetricType(typeURL string) string {
    	return model.GetMetricType(typeURL)
    }
    
    // GetResourceType returns resource form of an abbreviated form
    func GetResourceType(shortType string) string {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Apr 04 20:29:08 UTC 2024
    - 2K bytes
    - Viewed (0)
  2. pkg/model/xds.go

    		return "ECDS"
    	case AddressType, WorkloadType:
    		return "WDS"
    	case WorkloadAuthorizationType:
    		return "WADS"
    	default:
    		return typeURL
    	}
    }
    
    // GetMetricType returns the form of a type reported for metrics
    func GetMetricType(typeURL string) string {
    	switch typeURL {
    	case ClusterType:
    		return "cds"
    	case ListenerType:
    		return "lds"
    	case RouteType:
    		return "rds"
    	case EndpointType:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Apr 04 20:29:08 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  3. pilot/pkg/xds/monitoring.go

    		}
    		return true
    	}
    	return false
    }
    
    func recordPushTime(xdsType string, duration time.Duration) {
    	pushTime.With(typeTag.Value(v3.GetMetricType(xdsType))).Record(duration.Seconds())
    	pushes.With(typeTag.Value(v3.GetMetricType(xdsType))).Increment()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 00:26:45 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  4. pkg/xds/monitoring.go

    		[]float64{.01, .1, 1, 3, 5, 10, 20, 30},
    	)
    )
    
    func IncrementXDSRejects(xdsType string, node, errCode string) {
    	totalXDSRejects.With(typeTag.Value(model.GetMetricType(xdsType))).Increment()
    	switch xdsType {
    	case model.ListenerType:
    		ldsReject.With(nodeTag.Value(node), errTag.Value(errCode)).Increment()
    	case model.ClusterType:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 00:26:45 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  5. pkg/xds/server.go

    				id, request.ResponseNonce)
    		}
    		log.Debugf("ADS:%s: REQ %s Expired nonce received %s, sent %s", stype,
    			id, request.ResponseNonce, previousInfo.NonceSent)
    		ExpiredNonce.With(typeTag.Value(model.GetMetricType(request.TypeUrl))).Increment()
    		return false, emptyResourceDelta
    	}
    
    	// If it comes here, that means nonce match.
    	var previousResources []string
    	var alwaysRespond bool
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 13 20:55:20 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  6. pilot/pkg/xds/delta.go

    		deltaLog.Debugf("ADS:%s: REQ %s Expired nonce received %s, sent %s", stype,
    			con.ID(), request.ResponseNonce, previousInfo.NonceSent)
    		xds.ExpiredNonce.With(typeTag.Value(v3.GetMetricType(request.TypeUrl))).Increment()
    		return false
    	}
    	// If it comes here, that means nonce match. This an ACK. We should record
    	// the ack details and respond if there is a change in resource names.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 25.6K bytes
    - Viewed (0)
Back to top