metrics

type Conf struct {
	Type                  metricsType       `yaml:"type" json:"type" toml:"type"`
	Mode                  mode              `yaml:"mode" json:"mode" toml:"mode"`
	Interval              string            `yaml:"interval" json:"interval" toml:"interval"`
	Endpoint              *endpointConf     `yaml:"endpoint" json:"endpoint" toml:"endpoint"`
	Labels                map[string]string `yaml:"labels" json:"labels" toml:"labels"`
	EnableServiceLabel    bool              `yaml:"enable_service_label" json:"enable_service_label" toml:"enable_service_label"`
	EnableInternalMetrics bool              `yaml:"enable_internal_metrics" json:"enable_internal_metrics" toml:"enable_internal_metrics"`
	QueueLimit            int               `yaml:"queue_limit" json:"queue_limit" toml:"queue_limit" default:"16384"`
	QueueConcurrency      int               `yaml:"queue_concurrency" json:"queue_concurrency" toml:"queue_concurrency"`
	Logger                string            `yaml:"logger" json:"logger" toml:"logger" default:"github.com/wfusion/gofusion/log/customlogger.metricsLogger"`
	LogInstance           string            `yaml:"log_instance" json:"log_instance" toml:"log_instance"`
	EnableLogger          bool              `yaml:"enable_logger" json:"enable_logger" toml:"enable_logger" default:"false"`
}

type Label struct {
	Key, Value string
}

type Sink interface {
	// SetGauge A Gauge should retain the last value it is set to
	SetGauge(ctx context.Context, key []string, val float64, opts ...utils.OptionExtender)

	// IncrCounter Counters should accumulate values
	IncrCounter(ctx context.Context, key []string, val float64, opts ...utils.OptionExtender)

	// AddSample Samples are for timing information, where quantiles are used
	AddSample(ctx context.Context, key []string, val float64, opts ...utils.OptionExtender)

	// MeasureSince A better way to add timer samples
	MeasureSince(ctx context.Context, key []string, start time.Time, opts ...utils.OptionExtender)

	// IsEnableServiceLabel check if enable service label
	IsEnableServiceLabel() bool
	// contains filtered or unexported methods
}