ingest

type BatchError interface {
	error
	Errors() []error
	LastError() error
}

type DownsampleAndWriteIter interface {
	Next() bool
	Current() IterValue
	Reset() error
	Error() error
	SetCurrentMetadata(ts.Metadata)
}

type DownsamplerAndWriter interface {
	Write(
		ctx context.Context,
		tags models.Tags,
		datapoints ts.Datapoints,
		unit xtime.Unit,
		annotation []byte,
		overrides WriteOptions,
		source ts.SourceType,
	) error

	WriteBatch(
		ctx context.Context,
		iter DownsampleAndWriteIter,
		overrides WriteOptions,
	) BatchError

	Storage() storage.Storage

	Downsampler() downsample.Downsampler
}

type IterValue struct {
	Tags       models.Tags
	Datapoints ts.Datapoints
	Attributes ts.SeriesAttributes
	Unit       xtime.Unit
	Metadata   ts.Metadata
	Annotation []byte
}

type LatencyBuckets struct {
	WriteLatencyBuckets  tally.DurationBuckets
	IngestLatencyBuckets tally.DurationBuckets
}

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

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

type WriteOptions struct {
	DownsampleMappingRules []downsample.AutoMappingRule
	WriteStoragePolicies   []policy.StoragePolicy

	DownsampleOverride bool
	WriteOverride      bool
}