tem

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

type BlockControl interface {
	ReadDone()
}

type BlockMeta struct {
	// Unique identifier for the block and its contents. Changes on compaction.
	ULID ulid.ULID `json:"ulid"`

	// MinTime and MaxTime specify the time range all samples
	// in the block are in.
	MinTime int64 `json:"minTime"`
	MaxTime int64 `json:"maxTime"`

	LogID            []uint64 `json:"log_id"`
	Total            uint64   `json:"total"`
	SkipListLevel    int      `json:"skiplistlevel"`
	SkipListInterval int      `json:"SkipListInterval"`

	Compaction BlockMetaCompaction `json:"compaction"`
}

type BlockMetaCompaction struct {
	// Maximum number of compaction cycles any source block has
	// gone through.
	Level int `json:"level"`
	// ULIDs of all source head blocks that went into the block.
	Parents []ulid.ULID `json:"parents,omitempty"`
}

type BlockReader interface {
	Index() IndexReader

	Logs() LogReader

	MinTime() int64

	MaxTime() int64

	LogNum() uint64

	LastSegNum() uint64
}

type ChunkSeriesSet interface {
	Next() bool
	At() (labels.Labels, [][]chunks.Chunk)
	Err() error
}

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

type Head struct {
	MaxT int64
	// contains filtered or unexported fields
}

type IndexReader interface {
	MaxDoc() float64
	Search(lset []*prompb.LabelMatcher, expr temql.Expr) (posting.Postings, []series.Series)
	ChunkReader() chunks.ChunkReader
	Iterator() disk.IteratorLabel
	Close() error
}

type LogReader interface {
	ReadLog(uint64) []byte
	Iterator() disk.LogIterator
	Close() error
}

type MultiError []error

type Options struct {
	RetentionDuration uint64

	BlockRanges []int64

	DataDir string

	MaxBlockDuration int64

	FlushWritecoldDuration int64

	DefaultCacheSnapshotMemorySize int

	SkipListInterval int

	SkipListLevel int

	UseSkipList bool

	MsgTagName string
}

type Searcher interface {
	Search(lset []*prompb.LabelMatcher, expr temql.Expr, mint, maxt int64) SeriesSet
	Close() error
}

type Serices interface {
}

type Series interface {
	// Labels returns the complete set of labels identifying the series.
	Labels() labels.Labels

	// Iterator returns a new iterator of the data of the series.
	Iterator() SeriesIterator
}

type SeriesIterator interface {
	At() (t int64, v uint64, pos []int, b []byte)
	// Next advances the iterator by one.
	Next() bool
	// Err returns the current error.
	Err() error
}

type SeriesSet interface {
	Next() bool
	At() Series
	Err() error
}

type Wal interface {
	// contains filtered or unexported methods
}