Documentation ¶
Index ¶
- Constants
- Variables
- func NewBlochawkobserveer(b BlockReader) *blockSearcher
- func TraceAll()
- type Block
- type BlockControl
- type BlockMeta
- type BlockMetaCompaction
- type BlockReader
- type ChunkSeriesSet
- type Engine
- type Head
- type IndexReader
- type LogReader
- type MultiError
- type Options
- type Searcher
- type Serices
- type Series
- type SeriesIterator
- type SeriesSet
- type Wal
Constants ¶
const (
DefaultCacheSnapshotMemorySize = 25 * 1024 * 1024 // 25MB
)
Variables ¶
var ErrClosing = errors.New("block is closing")
Functions ¶
func NewBlochawkobserveer ¶
func NewBlochawkobserveer(b BlockReader) *blockSearcher
Types ¶
type Block ¶
type Block struct {
// contains filtered or unexported fields
}
func (*Block) Index ¶
func (b *Block) Index() IndexReader
func (*Block) LastSegNum ¶
type BlockControl ¶
type BlockControl interface {
ReadDone()
}
type BlockMeta ¶
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 ¶
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"` }
BlockMetaCompaction holds information about compactions a block went through.
type BlockReader ¶
type ChunkSeriesSet ¶
type Engine ¶
type Engine struct {
// contains filtered or unexported fields
}
func (*Engine) ShouldCompactMem ¶
type Head ¶
type Head struct { MaxT int64 // contains filtered or unexported fields }
func (*Head) Index ¶
func (h *Head) Index() IndexReader
func (*Head) LastSegNum ¶
type IndexReader ¶
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 ¶
type LogReader interface { ReadLog(uint64) []byte Iterator() disk.LogIterator Close() error }
type MultiError ¶
type MultiError []error
The MultiError type implements the error interface, and contains the Errors used to construct it.
func (*MultiError) Add ¶
func (es *MultiError) Add(err error)
Add adds the error to the error list if it is not nil.
func (MultiError) Err ¶
func (es MultiError) Err() error
Err returns the error list as an error or nil if it is empty.
func (MultiError) Error ¶
func (es MultiError) Error() string
Returns a concatenated string of the contained errors
type Series ¶
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 }
Series exposes a single time series.
type 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 }
SeriesIterator iterates over the data of a time series.
type SeriesSet ¶
SeriesSet contains a set of series.
func NewMergedSeriesSet ¶
NewMergedSeriesSet takes two series sets as a single series set. The input series sets must be sorted and sequential in time, i.e. if they have the same label set, the datapoints of a must be before the datapoints of b.