metrics

type AggregateByFunc func(username, hostname string) string

type AggregateMetricsOptions struct {
	TimeResolution TimeResolutionFunc
	AggregateBy    AggregateByFunc
}

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

type Distribution[T constraints.Integer | constraints.Float] struct {
	// contains filtered or unexported fields
}

type DistributionState[T constraints.Float | constraints.Integer] struct {
	Min              T       `json:"min"`
	Max              T       `json:"max"`
	Sum              T       `json:"sum"`
	Count            int64   `json:"count"`
	BucketCounters   []int64 `json:"buckets"`
	BucketThresholds []T     `json:"-"`
}

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

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

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

type Snapshot struct {
	StartTime time.Time `json:"startTime"`
	EndTime   time.Time `json:"endTime"`
	User      string    `json:"user"`
	Hostname  string    `json:"hostname"`

	Counters              map[string]int64                             `json:"counters"`
	DurationDistributions map[string]*DistributionState[time.Duration] `json:"durationDistributions"`
	SizeDistributions     map[string]*DistributionState[int64]         `json:"sizeDistributions"`
}

type SnapshotValueAggregator[T any] interface {
	FromSnapshot(s *Snapshot) (T, bool)
	Aggregate(previousAggregate T, incoming T, ratio float64) T
}

type Thresholds[T constraints.Float | constraints.Integer] struct {
	// contains filtered or unexported fields
}

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

type TimeResolutionFunc func(time.Time) (time.Time, time.Time)

type TimeSeries[T any] []TimeSeriesPoint[T]

type TimeSeriesPoint[T any] struct {
	Time  time.Time
	Value T
}

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