msgpack

type AggregatedEncoder interface {
	// EncodeMetricWithStoragePolicy encodes a metric with an applicable storage policy.
	EncodeMetricWithStoragePolicy(mp aggregated.MetricWithStoragePolicy) error

	// EncodeMetricWithStoragePolicyAndEncodeTime encodes a metric with an applicable
	// storage policy, alongside the time at which encoding happens.
	EncodeMetricWithStoragePolicyAndEncodeTime(
		mp aggregated.MetricWithStoragePolicy,
		encodedAtNanos int64,
	) error

	// EncodeChunkedMetricWithStoragePolicy encodes a chunked metric with an applicable storage policy.
	EncodeChunkedMetricWithStoragePolicy(cmp aggregated.ChunkedMetricWithStoragePolicy) error

	// EncodeChunkedMetricWithStoragePolicyAndEncodeTime encodes a chunked metric with
	// an applicable storage policy, alongside the time at which encoding happens.
	EncodeChunkedMetricWithStoragePolicyAndEncodeTime(
		cmp aggregated.ChunkedMetricWithStoragePolicy,
		encodedAtNanos int64,
	) error

	// Encoder returns the encoder.
	Encoder() BufferedEncoder

	// Reset resets the encoder.
	Reset(encoder BufferedEncoder)
}

type AggregatedIterator interface {
	// Next returns true if there are more metrics to decode.
	Next() bool

	// Value returns the current raw metric, the corresponding policy, and timestamp at
	// which the metric and the policy were encoded if applicable.
	Value() (aggregated.RawMetric, policy.StoragePolicy, int64)

	// Err returns the error encountered during decoding, if any.
	Err() error

	// Reset resets the iterator.
	Reset(reader io.Reader)

	// Close closes the iterator.
	Close()
}

type AggregatedIteratorAlloc func() AggregatedIterator

type AggregatedIteratorOptions interface {
	// SetIgnoreHigherVersion determines whether the iterator ignores messages
	// with higher-than-supported version.
	SetIgnoreHigherVersion(value bool) AggregatedIteratorOptions

	// IgnoreHigherVersion returns whether the iterator ignores messages with
	// higher-than-supported version.
	IgnoreHigherVersion() bool

	// SetReaderBufferSize sets the reader buffer size.
	SetReaderBufferSize(value int) AggregatedIteratorOptions

	// ReaderBufferSize returns the reader buffer size.
	ReaderBufferSize() int

	// SetIteratorPool sets the aggregated iterator pool.
	SetIteratorPool(value AggregatedIteratorPool) AggregatedIteratorOptions

	// IteratorPool returns the aggregated iterator pool.
	IteratorPool() AggregatedIteratorPool
}

type AggregatedIteratorPool interface {
	// Init initializes the aggregated iterator pool.
	Init(alloc AggregatedIteratorAlloc)

	// Get returns an aggregated iterator from the pool.
	Get() AggregatedIterator

	// Put puts an aggregated iterator into the pool.
	Put(it AggregatedIterator)
}

type Buffer interface {
	// Buffer returns the bytes buffer.
	Buffer() *bytes.Buffer

	// Bytes returns the buffered bytes.
	Bytes() []byte

	// Reset resets the buffer.
	Reset()

	// Close closes the buffer.
	Close()
}

type BufferedEncoder interface {
	Buffer
	Encoder
}

type BufferedEncoderAlloc func() BufferedEncoder

type BufferedEncoderPool interface {
	// Init initializes the buffered encoder pool.
	Init(alloc BufferedEncoderAlloc)

	// Get returns a buffered encoder from the pool.
	Get() BufferedEncoder

	// Put puts a buffered encoder into the pool.
	Put(enc BufferedEncoder)
}

type BufferedEncoderPoolOptions interface {
	// SetMaxCapacity sets the maximum capacity of buffers that can be returned to the pool.
	SetMaxCapacity(value int) BufferedEncoderPoolOptions

	// MaxBufferCapacity returns the maximum capacity of buffers that can be returned to the pool.
	MaxCapacity() int

	// SetObjectPoolOptions sets the object pool options.
	SetObjectPoolOptions(value pool.ObjectPoolOptions) BufferedEncoderPoolOptions

	// ObjectPoolOptions returns the object pool options.
	ObjectPoolOptions() pool.ObjectPoolOptions
}

type Encoder interface {
	// EncodeInt64 encodes an int64 value.
	EncodeInt64(value int64) error

	// EncodeBool encodes a boolean value.
	EncodeBool(value bool) error

	// EncodeFloat64 encodes a float64 value.
	EncodeFloat64(value float64) error

	// EncodeBytes encodes a byte slice.
	EncodeBytes(value []byte) error

	// EncodeBytesLen encodes the length of a byte slice.
	EncodeBytesLen(value int) error

	// EncodeArrayLen encodes the length of an array.
	EncodeArrayLen(value int) error
}

type UnaggregatedEncoder interface {
	// EncodeCounter encodes a counter.
	EncodeCounter(c unaggregated.Counter) error

	// EncodeBatchTimer encodes a batch timer.
	EncodeBatchTimer(bt unaggregated.BatchTimer) error

	// EncodeGauge encodes a gauge.
	EncodeGauge(g unaggregated.Gauge) error

	// EncodeCounterWithPoliciesList encodes a counter with applicable policies list.
	EncodeCounterWithPoliciesList(cp unaggregated.CounterWithPoliciesList) error

	// EncodeBatchTimerWithPoliciesList encodes a batched timer with applicable policies list.
	EncodeBatchTimerWithPoliciesList(btp unaggregated.BatchTimerWithPoliciesList) error

	// EncodeGaugeWithPoliciesList encodes a gauge with applicable policies list.
	EncodeGaugeWithPoliciesList(gp unaggregated.GaugeWithPoliciesList) error

	// Encoder returns the encoder.
	Encoder() BufferedEncoder

	// Reset resets the encoder.
	Reset(encoder BufferedEncoder)
}

type UnaggregatedIterator interface {
	// Next returns true if there are more items to decode.
	Next() bool

	// Metric returns the current metric.
	// The returned value remains valid until the next Next() call.
	Metric() unaggregated.MetricUnion

	// PoliciesList returns the current applicable policies list.
	// The returned value remains valid until the next Next() call.
	PoliciesList() policy.PoliciesList

	// Err returns the error encountered during decoding, if any.
	Err() error

	// Reset resets the iterator.
	Reset(reader io.Reader)

	// Close closes the iterator.
	Close()
}

type UnaggregatedIteratorAlloc func() UnaggregatedIterator

type UnaggregatedIteratorOptions interface {
	// SetIgnoreHigherVersion determines whether the iterator ignores messages
	// with higher-than-supported version.
	SetIgnoreHigherVersion(value bool) UnaggregatedIteratorOptions

	// IgnoreHigherVersion returns whether the iterator ignores messages with
	// higher-than-supported version.
	IgnoreHigherVersion() bool

	// SetReaderBufferSize sets the reader buffer size.
	SetReaderBufferSize(value int) UnaggregatedIteratorOptions

	// ReaderBufferSize returns the reader buffer size.
	ReaderBufferSize() int

	// SetLargeFloatsSize determines whether a float slice is considered a "large"
	// slice and therefore resort to the pool for allocating that slice.
	SetLargeFloatsSize(value int) UnaggregatedIteratorOptions

	// LargeFloatsSize returns whether a float slice is considered a "large"
	// slice and therefore resort to the pool for allocating that slice.
	LargeFloatsSize() int

	// SetLargeFloatsPool sets the large floats pool.
	SetLargeFloatsPool(value pool.FloatsPool) UnaggregatedIteratorOptions

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

	// SetIteratorPool sets the unaggregated iterator pool.
	SetIteratorPool(value UnaggregatedIteratorPool) UnaggregatedIteratorOptions

	// IteratorPool returns the unaggregated iterator pool.
	IteratorPool() UnaggregatedIteratorPool
}

type UnaggregatedIteratorPool interface {
	// Init initializes the unaggregated iterator pool.
	Init(alloc UnaggregatedIteratorAlloc)

	// Get returns an unaggregated iterator from the pool.
	Get() UnaggregatedIterator

	// Put puts an unaggregated iterator into the pool.
	Put(it UnaggregatedIterator)
}