storage

package
v1.7.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 12, 2018 License: MIT Imports: 20 Imported by: 0

Documentation

Overview

Package storage is a generated protocol buffer package.

It is generated from these files:

source.proto

It has these top-level messages:

ReadSource

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthSource = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSource   = fmt.Errorf("proto: integer overflow")
)
View Source
var (
	ErrMissingReadSource = errors.New("missing ReadSource")
)

Functions

func HasFieldKeyOrValue

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

func HasSingleMeasurementNoOR added in v1.6.1

func HasSingleMeasurementNoOR(expr influxql.Expr) (string, bool)

HasSingleMeasurementNoOR determines if an index optimisation is available.

Typically the read service will use the query engine to retrieve all field keys for all measurements that match the expression, which can be very inefficient if it can be proved that only one measurement matches the expression.

This condition is determined when the following is true:

  • there is only one occurrence of the tag key `_measurement`.
  • there are no OR operators in the expression tree.
  • the operator for the `_measurement` binary expression is ==.

func NewContextWithReadOptions added in v1.7.2

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 added in v1.7.0

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

type ReadOptions added in v1.7.2

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 added in v1.7.2

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 added in v1.7.0

type ReadSource struct {
	// Database identifies which database to query.
	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	// RetentionPolicy identifies which retention policy to query.
	RetentionPolicy string `protobuf:"bytes,2,opt,name=retention_policy,json=retentionPolicy,proto3" json:"retention_policy,omitempty"`
}

func GetReadSource added in v1.7.2

func GetReadSource(req *datatypes.ReadRequest) (*ReadSource, error)

GetReadSource will attempt to unmarshal a ReadSource from the ReadRequest or return an error if no valid resource is present.

func (*ReadSource) Descriptor added in v1.7.0

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

func (*ReadSource) Marshal added in v1.7.0

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

func (*ReadSource) MarshalTo added in v1.7.0

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

func (*ReadSource) ProtoMessage added in v1.7.0

func (*ReadSource) ProtoMessage()

func (*ReadSource) Reset added in v1.7.0

func (m *ReadSource) Reset()

func (*ReadSource) Size added in v1.7.0

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

func (*ReadSource) String added in v1.7.0

func (m *ReadSource) String() string

func (*ReadSource) Unmarshal added in v1.7.0

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

type Store

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

func NewStore

func NewStore(store *tsdb.Store, metaClient MetaClient) *Store

func (*Store) GetSource added in v1.7.0

func (s *Store) GetSource(rs storage.ReadSpec) (proto.Message, error)

func (*Store) GroupRead added in v1.6.0

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

func (*Store) Read

func (*Store) WithLogger

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

WithLogger sets the logger for the service.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL