observability

type BoundedAsyncQueue[T any] struct {
	// contains filtered or unexported fields
}

type Counter interface {
	Inc()
	Add(float64)
}

type CounterSpec struct {
	Name   string
	Help   string
	Labels []string
}

type CounterVec struct {
	// contains filtered or unexported fields
}

type Gauge interface {
	Set(float64)
}

type GaugeSpec struct {
	Name   string
	Help   string
	Labels []string
}

type GaugeVec struct {
	// contains filtered or unexported fields
}

type Histogram interface {
	Observe(float64)
}

type HistogramSpec struct {
	Name    string
	Help    string
	Labels  []string
	Buckets []float64
}

type HistogramVec struct {
	// contains filtered or unexported fields
}

type MetricsFactory struct {
	// contains filtered or unexported fields
}

type ReadSampleConfig struct {
	Min        int
	Max        int
	Multiplier int
}

type RedisTopKConfig struct {
	Prefix           string
	DefaultTTL       time.Duration
	OperationTimeout time.Duration
	ReadSample       ReadSampleConfig
}

type RedisTopKStore struct {
	// contains filtered or unexported fields
}

type Runtime struct {
	// contains filtered or unexported fields
}

type RuntimeConfig struct {
	Registerer prometheus.Registerer
	Gatherer   prometheus.Gatherer
}

type SortedSetClient interface {
	ZIncrByWithExpire(ctx context.Context, key string, increment float64, member string, ttl time.Duration) (float64, error)
	ZRevRangeWithScores(ctx context.Context, key string, start, stop int64) ([]SortedSetMember, error)
}

type SortedSetMember struct {
	Member string
	Score  float64
}

type TopKDelta struct {
	Metric string
	Value  float64
}

type TopKListRequest struct {
	Now     time.Time
	Days    int
	Metrics []string
	Limit   int
}

type TopKMember struct {
	Member string
	Scores map[string]float64
}