yatsdb

type InvertedIndexUpdater interface {
	//set labels to streamID indexß
	Insert(streamMetric invertedindex.StreamMetric) error
}

type MetricSampleIteratorCreater interface {
	CreateSampleSampleIterator(StreamMetric *StreamMetricOffset) (SampleIterator, error)
}

type MetricsQuerier interface {
	Query(matchers *[]prompb.LabelMatcher) (*[]model.Metric, error)
}

type OffsetIndexUpdater = ssoffsetindex.OffsetIndexUpdater

type Options struct {
	BadgerDBStoreDir       string                                 `yaml:"badger_db_store_dir"`
	EnableStreamStore      bool                                   `yaml:"enable_stream_store"`
	EnableTBOffsetIndex    bool                                   `yaml:"enable_tb_offset_index"`
	ReadGorutines          int                                    `yaml:"read_gorutines"`
	StreamStoreOptions     streamstore.Options                    `yaml:"stream_store_options"`
	FileStreamStoreOptions filestreamstore.FileStreamStoreOptions `yaml:"file_stream_store_options"`
	OffsetIndexOptions     tboffsetindex.Options                  `yaml:"offset_index_options"`
	Debug                  struct {
		DumpReadRequestResponse bool `yaml:"dump_read_request_response"`
		LogWriteStat            bool `yaml:"log_write_stat"`
	} `yaml:"debug"`

	Registerer prometheus.Registerer `yaml:"-"`
}

type SampleIterator interface {
	//io.EOF end of stream
	Next() (prompb.Sample, error)
	Close() error
}

type SamplesWriter interface {
	Write(ID StreamID, samples []prompb.Sample, fn WriteSampleCallback)
}

type SeriesStreamOffset = ssoffsetindex.SeriesStreamOffset

type StreamID = invertedindex.StreamID

type StreamMetricOffset struct {
	invertedindex.StreamMetric

	Offset int64
	//
	StartTimestampMs int64
	//
	EndTimestampMs int64
}

type StreamMetricQuerier interface {
	QueryStreamMetric(*prompb.Query) ([]*StreamMetricOffset, error)
}

type TSDB interface {
	WriteSamples(*prompb.WriteRequest) error
	ReadSamples(ctx context.Context, request *prompb.ReadRequest) (*prompb.ReadResponse, error)
}

type WriteSampleCallback func(offset SeriesStreamOffset, err error)