storage

Documentation

Index

• Variables
• func HasFieldKeyOrValue(expr influxql.Expr) (bool, bool)
• func NewContextWithReadOptions(ctx context.Context, opts *ReadOptions) context.Context
• func RewriteExprRemoveFieldKeyAndValue(expr influxql.Expr) influxql.Expr
• type MetaClient
• type ReadOptions
  • func ReadOptionsFromContext(ctx context.Context) *ReadOptions
• type ReadSource
  • func GetReadSource(any types.Any) (*ReadSource, error)
  • func (*ReadSource) Descriptor() ([]byte, []int)
  • func (r *ReadSource) GetBucketID() influxdb.ID
  • func (r *ReadSource) GetOrgID() influxdb.ID
  • func (m *ReadSource) Marshal() (dAtA []byte, err error)
  • func (m *ReadSource) MarshalTo(dAtA []byte) (int, error)
  • func (m *ReadSource) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*ReadSource) ProtoMessage()
  • func (m *ReadSource) Reset()
  • func (m *ReadSource) Size() (n int)
  • func (m *ReadSource) String() string
  • func (m *ReadSource) Unmarshal(dAtA []byte) error
  • func (m *ReadSource) XXX_DiscardUnknown()
  • func (m *ReadSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ReadSource) XXX_Merge(src proto.Message)
  • func (m *ReadSource) XXX_Size() int
  • func (m *ReadSource) XXX_Unmarshal(b []byte) error
• type Store
  • func NewStore(store TSDBStore, metaClient MetaClient) *Store
  • func (s *Store) GetSource(orgID, bucketID uint64) proto.Message
  • func (s *Store) MeasurementNames(ctx context.Context, mqAttrs *metaqueryAttributes) (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) ReadSeriesCardinality(ctx context.Context, req *datatypes.ReadSeriesCardinalityRequest) (cursors.Int64Iterator, error)
  • func (s *Store) SupportReadSeriesCardinality(ctx context.Context) bool
  • 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) WindowAggregate(ctx context.Context, req *datatypes.ReadWindowAggregateRequest) (reads.ResultSet, error)
  • func (s *Store) WithLogger(log *zap.Logger)
• type TSDBStore

Variables

var (
	ErrInvalidLengthSource        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSource          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupSource = fmt.Errorf("proto: unexpected end of group")
)

var (
	ErrMissingReadSource = errors.New("missing ReadSource")
)

Functions

func HasFieldKeyOrValue

func HasFieldKeyOrValue(expr influxql.Expr) (bool, bool)

func NewContextWithReadOptions

func NewContextWithReadOptions(ctx context.Context, opts *ReadOptions) context.Context

NewContextWithRequestOptions returns a new Context with nodeID added.

func RewriteExprRemoveFieldKeyAndValue

func RewriteExprRemoveFieldKeyAndValue(expr influxql.Expr) influxql.Expr

Types

type MetaClient

type MetaClient interface {
	Database(name string) *meta.DatabaseInfo
	ShardGroupsByTimeRange(database, policy string, min, max time.Time) (a []meta.ShardGroupInfo, err error)
}

type ReadOptions

type ReadOptions struct {
	NodeID uint64
}

ReadOptions are additional options that may be passed with context.Context to configure the behavior of a storage read request.

func ReadOptionsFromContext

func ReadOptionsFromContext(ctx context.Context) *ReadOptions

ReadOptionsFromContext returns the ReadOptions associated with the context or nil if no additional options have been specified.

type ReadSource

type ReadSource struct {
	// OrgID specifies the organization identifier for this request.
	OrgID uint64 `protobuf:"varint,1,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"`
	// BucketID specifies the bucket in the organization.
	BucketID uint64 `protobuf:"varint,2,opt,name=bucket_id,json=bucketId,proto3" json:"bucket_id,omitempty"`
}

func GetReadSource

func GetReadSource(any types.Any) (*ReadSource, error)

func (*ReadSource) Descriptor

func (*ReadSource) Descriptor() ([]byte, []int)

func (*ReadSource) GetBucketID

func (r *ReadSource) GetBucketID() influxdb.ID

func (*ReadSource) GetOrgID

func (r *ReadSource) GetOrgID() influxdb.ID

func (*ReadSource) Marshal

func (m *ReadSource) Marshal() (dAtA []byte, err error)

func (*ReadSource) MarshalTo

func (m *ReadSource) MarshalTo(dAtA []byte) (int, error)

func (*ReadSource) MarshalToSizedBuffer

func (m *ReadSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadSource) ProtoMessage

func (*ReadSource) ProtoMessage()

func (*ReadSource) Reset

func (m *ReadSource) Reset()

func (*ReadSource) Size

func (m *ReadSource) Size() (n int)

func (*ReadSource) String

func (m *ReadSource) String() string

func (*ReadSource) Unmarshal

func (m *ReadSource) Unmarshal(dAtA []byte) error

func (*ReadSource) XXX_DiscardUnknown

func (m *ReadSource) XXX_DiscardUnknown()

func (*ReadSource) XXX_Marshal

func (m *ReadSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadSource) XXX_Merge

func (m *ReadSource) XXX_Merge(src proto.Message)

func (*ReadSource) XXX_Size

func (m *ReadSource) XXX_Size() int

func (*ReadSource) XXX_Unmarshal

func (m *ReadSource) XXX_Unmarshal(b []byte) error

type Store

type Store struct {
	TSDBStore  TSDBStore
	MetaClient MetaClient
	Logger     *zap.Logger
}

func NewStore

func NewStore(store TSDBStore, metaClient MetaClient) *Store

func (*Store) GetSource

func (s *Store) GetSource(orgID, bucketID uint64) proto.Message

func (*Store) MeasurementNames

func (s *Store) MeasurementNames(ctx context.Context, mqAttrs *metaqueryAttributes) (cursors.StringIterator, error)

func (*Store) ReadFilter

func (s *Store) ReadFilter(ctx context.Context, req *datatypes.ReadFilterRequest) (reads.ResultSet, error)

func (*Store) ReadGroup

func (s *Store) ReadGroup(ctx context.Context, req *datatypes.ReadGroupRequest) (reads.GroupResultSet, error)

func (*Store) ReadSeriesCardinality

func (s *Store) ReadSeriesCardinality(ctx context.Context, req *datatypes.ReadSeriesCardinalityRequest) (cursors.Int64Iterator, error)

func (*Store) SupportReadSeriesCardinality

func (s *Store) SupportReadSeriesCardinality(ctx context.Context) bool

func (*Store) TagKeys

func (s *Store) TagKeys(ctx context.Context, req *datatypes.TagKeysRequest) (cursors.StringIterator, error)

func (*Store) TagValues

func (s *Store) TagValues(ctx context.Context, req *datatypes.TagValuesRequest) (cursors.StringIterator, error)

func (*Store) WindowAggregate

func (s *Store) WindowAggregate(ctx context.Context, req *datatypes.ReadWindowAggregateRequest) (reads.ResultSet, error)

func (*Store) WithLogger

func (s *Store) WithLogger(log *zap.Logger)

WithLogger sets the logger for the service.

type TSDBStore

type TSDBStore interface {
	MeasurementNames(ctx context.Context, auth query.Authorizer, database string, cond influxql.Expr) ([][]byte, error)
	ShardGroup(ids []uint64) tsdb.ShardGroup
	Shards(ids []uint64) []*tsdb.Shard
	TagKeys(ctx context.Context, auth query.Authorizer, shardIDs []uint64, cond influxql.Expr) ([]tsdb.TagKeys, error)
	TagValues(ctx context.Context, auth query.Authorizer, shardIDs []uint64, cond influxql.Expr) ([]tsdb.TagValues, error)
	SeriesCardinality(ctx context.Context, database string) (int64, error)
	SeriesCardinalityFromShards(ctx context.Context, shards []*tsdb.Shard) (*tsdb.SeriesIDSet, error)
	SeriesFile(database string) *tsdb.SeriesFile
}