storage

package

v1.7.9 Latest Latest Go to latest Published: Oct 27, 2019 License: MIT Imports: 20 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/GrimbiXcode/influxdb

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 ¶

Variables
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
type MetaClient
type ReadOptions
- func ReadOptionsFromContext(ctx context.Context) *ReadOptions
type ReadSource
- func GetReadSource(any types.Any) (*ReadSource, error)
type Store
- func NewStore(store *tsdb.Store, metaClient MetaClient) *Store

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 ¶

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 ¶

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 MeasurementNamesRequest ¶

type MeasurementNamesRequest struct {
	MeasurementsSource *types.Any
	Predicate          *datatypes.Predicate
}

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 {
	// 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 ¶

func GetReadSource(any types.Any) (*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 ¶

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

func (*ReadSource) Marshal ¶

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

func (*ReadSource) MarshalTo ¶

func (m *ReadSource) MarshalTo(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

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 ¶

func (s *Store) GetSource(db, rp string) proto.Message

func (*Store) MeasurementNames ¶

func (s *Store) MeasurementNames(ctx context.Context, req *MeasurementNamesRequest) (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) 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) WithLogger ¶

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

WithLogger sets the logger for the service.

Source Files ¶

View all Source files

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