Package measure implements execution operations for querying measure data.

Package stream implements execution operations for querying stream data.

ApplyRules apply OptimizeRules to a Plan.

BuildSimpleTagFilter returns a TagFilter without any local-index, global index, sharding key support.

BuildTagFilter returns a TagFilter if predicates doesn't match any indices.

FormatTagRefs outputs formatted tag refs.

NewBytesLiteral creates a new instance of BytesLiteral with the provided slice of bytes.

NewField return a new Field.

NewPushDownMaxSize returns a new PushDownMaxSize.

NewPushDownOrder returns a new PushDownOrder.

NewSearchableTagRef is a short-handed method for creating a TagRef to the tag in the searchable family.

NewTag return a new Tag.

NewTagRef returns a new TagRef.

NewTags create an array of Tag within a TagFamily.

ParseEntities merges entities based on the logical operation.

ParseExprOrEntity parses the condition and returns the literal expression or the entities.

ParseOrderBy parses an OrderBy from a Schema.

StringSlicesEqual reports whether a and b are the same length and contain the same strings.

ToTags converts a projection spec to Tag sets.

DummyFilter matches any predicate.

ErrInvalidCriteriaType indicates an invalid criteria type.

ErrInvalidLogicalExpression indicates an invalid logical expression.

ErrUnsupportedConditionOp indicates an unsupported condition operation.

ErrUnsupportedConditionValue indicates an unsupported condition value type.

BytesLiteral represents a wrapper for a slice of bytes.

CommonSchema represents a sharable fields between independent schemas.

Field identity a field in a measure.

FieldRef is the reference to the field also it holds the definition (derived from measureSchema) of the field.

FieldSpec is the reference to the field.

OrderBy is the sorting operator.

Parent refers to a parent node in the execution tree(plan).

PushDownMaxSize pushes down the max volume to a Plan.

PushDownOrder pushes down the order to a Plan.

Tag represents the combination of tag family and tag name.

TagRef is the reference to the tag also it holds the definition (derived from the streamSchema, measureSchema) of the tag.

TagSpec wraps offsets to access a tag in the raw data swiftly.

ComparableExpr allows comparing Expr and Expr arrays.

Expr represents a predicate in criteria.

IndexChecker allows checking the existence of a specific index rule.

LiteralExpr allows getting raw data represented as bytes.

OptimizeRule allows optimizing a Plan based on a rule.

Plan is the executable operation.

Schema allows retrieving schemas in a convenient way.

Sorter sorts a Plan's output.

TagFilter allows matching a tag based on a predicate.

TagSpecRegistry enables to find TagSpec by its name.

TagValueIndexAccessor provides accessor to get TagValue by two indexes, i.e.

UnresolvedPlan denotes an logical expression.

VolumeLimiter controls the volume of a Plan's output.

TagFamilies wraps a slice of TagFamily.

TagFamiliesForWrite wraps a slice of TagFamilyForWrite.

TagSpecMap is a map of TapSpec implements TagSpecRegistry.