Versions in this module Expand all Collapse all v1 v1.2.0 Feb 29, 2024 Changes in this version + const PIECE_NUM + const VerticalFilterReaderDuration + const VerticalFilterReaderNumSpan + const VerticalFilterReaderSizeSpan + func Hash(bytes []byte) uint64 + type FilterReader struct + func NewFilterReader(option *obs.ObsOptions, expr influxql.Expr, splitMap map[string][]byte, ...) (*FilterReader, error) + func (s *FilterReader) Close() + func (s *FilterReader) IsExist(blockId int64, elem *rpn.SKRPNElement) (bool, error) + func (s *FilterReader) StartSpan(span *tracing.Span) + type LineFilterReader struct + func NewLineFilterReader(path string, obsOpts *obs.ObsOptions, expr influxql.Expr, version uint32, ...) (*LineFilterReader, error) + func (s *LineFilterReader) IsExist(blockId int64, elem *rpn.SKRPNElement) (bool, error) + type MultiFieldFilterReader struct + func NewMultiFieldFilterReader(option *obs.ObsOptions, expr []*SKRPNElement, splitMap map[string][]byte, ...) (*MultiFieldFilterReader, error) + func (s *MultiFieldFilterReader) Close() + func (s *MultiFieldFilterReader) IsExist(blockId int64, elem *rpn.SKRPNElement) (bool, error) + func (s *MultiFieldFilterReader) StartSpan(span *tracing.Span) + type MultiFiledLineFilterReader struct + func NewMultiFiledLineFilterReader(path string, obsOpts *obs.ObsOptions, expr []*SKRPNElement, version uint32, ...) (*MultiFiledLineFilterReader, error) + func (s *MultiFiledLineFilterReader) IsExist(blockId int64, elem *rpn.SKRPNElement) (bool, error) + type MultilFieldVerticalFilterReader struct + func NewMultiFieldVerticalFilterReader(path string, obsOpts *obs.ObsOptions, expr []*SKRPNElement, version uint32, ...) (*MultilFieldVerticalFilterReader, error) + func (s *MultilFieldVerticalFilterReader) IsExist(blockId int64, elem *rpn.SKRPNElement) (bool, error) + func (s *MultilFieldVerticalFilterReader) StartSpan(span *tracing.Span) + type SKRPNElement struct + Key string + Value string + func NewSKRPNElement(key, value string) *SKRPNElement + type VerticalFilterReader struct + func NewVerticalFilterReader(path string, obsOpts *obs.ObsOptions, expr influxql.Expr, version uint32, ...) (*VerticalFilterReader, error) + func (s *VerticalFilterReader) IsExist(blockId int64, elem *rpn.SKRPNElement) (bool, error) + func (s *VerticalFilterReader) StartSpan(span *tracing.Span)