cm

type Options interface {
	// SetEps sets the desired epsilon for errors.
	SetEps(value float64) Options

	// Eps returns the desired epsilon for errors.
	Eps() float64

	// SetCapacity sets the initial heap capacity.
	SetCapacity(value int) Options

	// Capacity returns the initial heap capacity.
	Capacity() int

	// SetInsertAndCompressEvery sets how frequently the timer values are
	// inserted into the stream and compressed to reduce write latency for
	// high frequency timers.
	SetInsertAndCompressEvery(value int) Options

	// InsertAndCompressEvery returns how frequently the timer values are
	// inserted into the stream and compressed to reduce write latency for
	// high frequency timers.
	InsertAndCompressEvery() int

	// SetFlushEvery sets how frequently the underlying stream is flushed
	// to reduce processing time when computing aggregated statistics from
	// the stream.
	SetFlushEvery(value int) Options

	// FlushEvery returns how frequently the underlying stream is flushed
	// to reduce processing time when computing aggregated statistics from
	// the stream.
	FlushEvery() int

	// SetStreamPool sets the stream pool.
	SetStreamPool(value StreamPool) Options

	// StreamPool returns the stream pool.
	StreamPool() StreamPool

	// SetSamplePool sets the sample pool.
	SetSamplePool(value SamplePool) Options

	// SamplePool returns the sample pool.
	SamplePool() SamplePool

	// SetFloatsPool sets the floats pool.
	SetFloatsPool(value pool.FloatsPool) Options

	// FloatsPool returns the floats pool.
	FloatsPool() pool.FloatsPool

	// Validate validates the options.
	Validate() error
}

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

type SamplePool interface {
	// Init initializes the pool.
	Init()

	// Get returns a sample from the pool.
	Get() *Sample

	// Put returns a sample to the pool.
	Put(sample *Sample)
}

type Stream interface {
	// Add adds a sample value.
	Add(value float64)

	// Flush flushes the internal buffer.
	Flush()

	// Min returns the minimum value.
	Min() float64

	// Max returns the maximum value.
	Max() float64

	// Quantile returns the quantile value.
	Quantile(q float64) float64

	// Close closes the stream.
	Close()

	// ResetSetData resets the stream and sets data.
	ResetSetData(quantiles []float64)
}

type StreamAlloc func() Stream

type StreamPool interface {
	// Init initializes the pool.
	Init(alloc StreamAlloc)

	// Get provides a stream from the pool.
	Get() Stream

	// Put returns a stream to the pool.
	Put(value Stream)
}