Versions in this module Expand all Collapse all v1 v1.2.0 Feb 29, 2024 Changes in this version + const BLOCK_FLUSH_TRIGGER_N_BYTES + const BLOCK_LOG_CHECK_N_BYTES + const BLOCK_LOG_NAME + const BLOCK_PREFIX_N_BYTES + const CONTENT_FIELD + const CONTENT_NAME + const CONTENT_RECORD_MAX_N_BYTES + const CONTENT_RECORD_PREFIX_N_BYTES + const CircularRecordNum + const ContentFilterDurationSpan + const FLAG_BLOCK_CHECK + const FLAG_CONTENT + const FLAG_HEAD_SHIFT + const FLAG_LENGTH_MASK + const FLAG_TAGS + const MAX_BLOCK_LOG_STORE_N_BYTES + const MAX_SCAN_META_COUNT + const MAX_SCAN_META_Length + const META_DATA_N_BYTES + const META_DATA_SIZE + const META_NAME + const META_STORE_N_BYTES + const MetaReadDurationSpan + const MetaReadNumSpan + const QueryMetaCacheTTL + const QueryMetaDataCacheSize + const RECORD_DATA_MAX_N_BYTES + const RECORD_MAX_N_BYTES + const ReaderContentSpan + const ReaderReadContentDuration + const ReaderReadContentSizeSpan + const RecordPoolNum + const TAGS_RECORD_PREFIX_N_BYTES + const TAG_FIELD + var FileCursorPool = record.NewRecordPool(record.LogStoreReaderPool) + var QueryMetaDataCache = cache.NewCache(QueryMetaDataCacheSize, QueryMetaCacheTTL) + func GetMetaLen(option *obs.ObsOptions, path string) (int64, error) + func PutMetaData(queryID string, meta []*MetaData) + func UpdateMetaData(old, new cache.Entry) bool + type BlockLogReader struct + func NewBlockLogReader(object *obs.ObsOptions, isStat bool, path string) (*BlockLogReader, error) + func (c *BlockLogReader) Close() + func (s *BlockLogReader) Next() ([][][]byte, int64, int, int64, error) + type ContentReader struct + func NewContentReader(option *obs.ObsOptions, path string, offset []int64, length []int64, ...) (*ContentReader, error) + func (s *ContentReader) Close() + func (s *ContentReader) Next() ([][][]byte, int64, error) + func (s *ContentReader) StartSpan(span *tracing.Span) + type DataReader struct + func NewDataReader(option *obs.ObsOptions, path string, version uint32, tr util.TimeRange, ...) (*DataReader, error) + func (s *DataReader) Close() + func (s *DataReader) Next() (*record.Record, error) + func (s *DataReader) StartSpan(span *tracing.Span) + func (s *DataReader) UnnestNext() (*record.Record, error) + type IndexReader struct + func NewIndexReader(option *obs.ObsOptions, version uint32, path string, tr util.TimeRange, ...) (*IndexReader, error) + func (s *IndexReader) Close() + func (s *IndexReader) Get() ([]*MetaData, error) + func (s *IndexReader) GetMaxBlockId() int64 + func (s *IndexReader) GetMinMaxTime() (int64, int64) + func (s *IndexReader) StartSpan(span *tracing.Span) + type MatchAllOperator struct + func (r *MatchAllOperator) Compute(rec *record.Record) + type MetaControl interface + IsEmpty func() bool + Pop func() (MetaDataInfo, bool) + Push func(MetaDataInfo) + func NewMetaControl(isQueue bool, count int) MetaControl + type MetaData struct + func GetMetaData(queryID string) ([]*MetaData, bool) + func NewMetaData(blockIndex int64, data []byte, offset int32) (*MetaData, error) + func (m *MetaData) GetBlockIndex() int64 + func (m *MetaData) GetContentBlockLength() int32 + func (m *MetaData) GetContentBlockOffset() int64 + func (m *MetaData) GetMaxTime() int64 + func (m *MetaData) GetMinTime() int64 + type MetaDataInfo interface + GetMaxTime func() int64 + GetMinTime func() int64 + type MetaDatas []*MetaData + func (a MetaDatas) Len() int + func (a MetaDatas) Less(i, j int) bool + func (a MetaDatas) Swap(i, j int) + type MetaQueue []MetaDataInfo + func (q *MetaQueue) IsEmpty() bool + func (q *MetaQueue) Pop() (MetaDataInfo, bool) + func (q *MetaQueue) Push(v MetaDataInfo) + type MetaReader interface + Close func() + func NewMetaReader(option *obs.ObsOptions, path string, offset int64, length int64, ...) (MetaReader, error) + type MetaStack []MetaDataInfo + func (s *MetaStack) IsEmpty() bool + func (s *MetaStack) Pop() (MetaDataInfo, bool) + func (s *MetaStack) Push(value MetaDataInfo) + type MetaStorageReader struct + func NewMetaStorageReader(option *obs.ObsOptions, path string, offset int64, length int64, ...) (*MetaStorageReader, error) + func (m *MetaStorageReader) Close() + type RegexpMatchAll struct + func (r *RegexpMatchAll) Get(data [][]byte) [][]byte + type SegmentMetaDataEntry struct + func NewSegmentMetaDataEntry(segmentID string) *SegmentMetaDataEntry + func (e *SegmentMetaDataEntry) GetKey() string + func (e *SegmentMetaDataEntry) GetTime() time.Time + func (e *SegmentMetaDataEntry) GetValue() interface{} + func (e *SegmentMetaDataEntry) SetTime(time time.Time) + func (e *SegmentMetaDataEntry) SetValue(value interface{}) + func (e *SegmentMetaDataEntry) Size() int64 + type SegmentReader struct + func NewSegmentReader(option *obs.ObsOptions, path string, version uint32, tr util.TimeRange, ...) (*SegmentReader, error) + func (s *SegmentReader) Close() + func (s *SegmentReader) GetRowCount() int64 + func (s *SegmentReader) Next() ([][][]byte, int64, error) + func (s *SegmentReader) SetTr(tr util.TimeRange) + func (s *SegmentReader) StartSpan(span *tracing.Span) + func (s *SegmentReader) UpdateTr(time int64) + type UnnestMatch interface + Get func([][]byte) [][]byte + func GetUnnestFunc(unnest *influxql.Unnest, schema record.Schemas) (UnnestMatch, error) + func NewRegexpMatchAll(unnest *influxql.Unnest, schema record.Schemas) UnnestMatch + type UnnestMatchAll struct + func NewUnnestMatchAll(unnest *influxql.Unnest) (*UnnestMatchAll, error) + func (r *UnnestMatchAll) Get(s string) map[string]string + type UnnestOperator interface + Compute func(rec *record.Record) + func GetUnnestFuncOperator(unnest *influxql.Unnest, schema record.Schemas) (UnnestOperator, error) + func NewMatchAllOperator(unnest *influxql.Unnest, schemas record.Schemas) UnnestOperator