Versions in this module Expand all Collapse all v1 v1.7.9 Oct 27, 2019 Changes in this version + var ErrIntOverflowSource = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthSource = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrMissingReadSource = errors.New("missing ReadSource") + func HasFieldKeyOrValue(expr influxql.Expr) (bool, bool) + func HasSingleMeasurementNoOR(expr influxql.Expr) (string, bool) + func NewContextWithReadOptions(ctx context.Context, opts *ReadOptions) context.Context + func RewriteExprRemoveFieldKeyAndValue(expr influxql.Expr) influxql.Expr + type MeasurementNamesRequest struct + MeasurementsSource *types.Any + Predicate *datatypes.Predicate + type MetaClient interface + Database func(name string) *meta.DatabaseInfo + ShardGroupsByTimeRange func(database, policy string, min, max time.Time) (a []meta.ShardGroupInfo, err error) + type ReadOptions struct + NodeID uint64 + func ReadOptionsFromContext(ctx context.Context) *ReadOptions + type ReadSource struct + Database string + RetentionPolicy string + func GetReadSource(any types.Any) (*ReadSource, error) + func (*ReadSource) Descriptor() ([]byte, []int) + func (*ReadSource) ProtoMessage() + func (m *ReadSource) Marshal() (dAtA []byte, err error) + func (m *ReadSource) MarshalTo(dAtA []byte) (int, error) + func (m *ReadSource) Reset() + func (m *ReadSource) Size() (n int) + func (m *ReadSource) String() string + func (m *ReadSource) Unmarshal(dAtA []byte) error + type Store struct + Logger *zap.Logger + MetaClient MetaClient + TSDBStore *tsdb.Store + func NewStore(store *tsdb.Store, metaClient MetaClient) *Store + func (s *Store) GetSource(db, rp string) proto.Message + func (s *Store) MeasurementNames(ctx context.Context, req *MeasurementNamesRequest) (cursors.StringIterator, error) + func (s *Store) ReadFilter(ctx context.Context, req *datatypes.ReadFilterRequest) (reads.ResultSet, error) + func (s *Store) ReadGroup(ctx context.Context, req *datatypes.ReadGroupRequest) (reads.GroupResultSet, error) + func (s *Store) TagKeys(ctx context.Context, req *datatypes.TagKeysRequest) (cursors.StringIterator, error) + func (s *Store) TagValues(ctx context.Context, req *datatypes.TagValuesRequest) (cursors.StringIterator, error) + func (s *Store) WithLogger(log *zap.Logger)