window

type Aggregation interface {
	// Min finds the min value within the window.
	Min() float64
	// Max finds the max value within the window.
	Max() float64
	// Avg computes average value within the window.
	Avg() float64
	// Sum computes sum value within the window.
	Sum() float64
}

type Bucket struct {
	Points []float64 // stores individual data points
	Count  int64     // number of data points in this bucket
	// contains filtered or unexported fields
}

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

type Metric interface {
	// Add adds the given value to the counter.
	Add(int64)
	// Value gets the current value.
	// If the metric's type is PointGauge, RollingCounter, RollingGauge,
	// it returns the sum value within the window.
	Value() int64
}

type Options struct {
	Size int
}

type RollingCounter interface {
	Metric
	Aggregation

	Timespan() int
	// Reduce applies the reduction function to all buckets within the window.
	Reduce(func(Iterator) float64) float64
}

type RollingCounterOpts struct {
	Size           int
	BucketDuration time.Duration
}

type RollingGauge interface {
	Metric
	Aggregation

	// Latest returns the latest value.
	Latest() float64
	Timespan() int
	// Reduce applies the reduction function to all buckets within the window.
	Reduce(func(Iterator) float64) float64
}

type RollingGaugeOpts struct {
	Size           int
	BucketDuration time.Duration
}

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

type RollingWindowOptions struct {
	Size           int           // Window size (number of buckets)
	BucketDuration time.Duration // Duration of each bucket
}

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