Function NewInt64Metric

pkg/util/metrics/metric_int64.go:45–81

NewInt64Metric create a Int64Metric metric, returns nil when viewName is empty.

(metricID MetricID, viewName string, description string, unit string, aggregation Aggregation, tagNames []string)

// NewInt64Metric create a Int64Metric metric, returns nil when viewName is empty.
func NewInt64Metric(metricID MetricID, viewName string, description string, unit string, aggregation Aggregation, tagNames []string) (*Int64Metric, error) {
	if viewName == "" {
		return nil, nil
	}

	MetricMap.AddMapping(metricID, viewName)

	tagKeys, err := getTagKeysFromNames(tagNames)
	if err != nil {
		return nil, fmt.Errorf("failed to create metric %q because of tag creation failure: %v", viewName, err)
	}

	var aggregationMethod *view.Aggregation
	switch aggregation {
	case LastValue:
		aggregationMethod = view.LastValue()
	case Sum:
		aggregationMethod = view.Sum()
	default:
		return nil, fmt.Errorf("unknown aggregation option %q", aggregation)
	}

	measure := stats.Int64(viewName, description, unit)
	newView := &view.View{
		Name:        viewName,
		Measure:     measure,
		Description: description,
		Aggregation: aggregationMethod,
		TagKeys:     tagKeys,
	}
	if err := view.Register(newView); err != nil {
		return nil, fmt.Errorf("failed to register view for metric %q: %v", viewName, err)
	}

	metric := Int64Metric{viewName, measure}
	return &metric, nil
}

// Record records a measurement for the metric, with provided tags as metric labels.
func (metric *Int64Metric) Record(tags map[string]string, measurement int64) error {