influxdb

package

Go to main page

Versions in this module

v1

v1.7.9

Oct 27, 2019

Changes in this version

type Dependencies

+ FluxDeps flux.Dependencies

+ StorageDeps StorageDependencies

+ func NewDependencies(mc MetaClient, reader Reader, auth Authorizer, authEnabled bool) (Dependencies, error)

+ func (d Dependencies) Inject(ctx context.Context) context.Context

+ type FromDependencies struct

+ AuthEnabled bool

+ Authorizer Authorizer

+ MetaClient MetaClient

+ Reader Reader

+ func (d FromDependencies) Validate() error

+ type StorageDependencies struct

+ AuthEnabled bool

+ Authorizer Authorizer

+ MetaClient MetaClient

+ Reader Reader

+ func GetStorageDependencies(ctx context.Context) StorageDependencies

+ func (d StorageDependencies) Inject(ctx context.Context) context.Context

+ func (d StorageDependencies) Validate() error

v1.7.9-dev1

Jun 12, 2020

v1.7.8

Aug 20, 2019

Changes in this version

+ const ReadGroupPhysKind

+ const ReadRangePhysKind

+ const ReadTagKeysPhysKind

+ const ReadTagValuesPhysKind

+ func ReadFilterSource(id execute.DatasetID, r Reader, readSpec ReadFilterSpec, ...) execute.Source

+ func ReadGroupSource(id execute.DatasetID, r Reader, readSpec ReadGroupSpec, ...) execute.Source

+ func ReadTagKeysSource(id execute.DatasetID, r Reader, readSpec ReadTagKeysSpec, ...) execute.Source

+ func ReadTagValuesSource(id execute.DatasetID, r Reader, readSpec ReadTagValuesSpec, ...) execute.Source

+ type PushDownFilterRule struct

+ func (PushDownFilterRule) Name() string

+ func (PushDownFilterRule) Pattern() plan.Pattern

+ func (PushDownFilterRule) Rewrite(pn plan.Node) (plan.Node, bool, error)

+ type PushDownGroupRule struct

+ func (rule PushDownGroupRule) Name() string

+ func (rule PushDownGroupRule) Pattern() plan.Pattern

+ func (rule PushDownGroupRule) Rewrite(node plan.Node) (plan.Node, bool, error)

+ type PushDownRangeRule struct

+ func (rule PushDownRangeRule) Name() string

+ func (rule PushDownRangeRule) Pattern() plan.Pattern

+ func (rule PushDownRangeRule) Rewrite(node plan.Node) (plan.Node, bool, error)

+ type PushDownReadTagKeysRule struct

+ func (rule PushDownReadTagKeysRule) Name() string

+ func (rule PushDownReadTagKeysRule) Pattern() plan.Pattern

+ func (rule PushDownReadTagKeysRule) Rewrite(pn plan.Node) (plan.Node, bool, error)

+ type PushDownReadTagValuesRule struct

+ func (rule PushDownReadTagValuesRule) Name() string

+ func (rule PushDownReadTagValuesRule) Pattern() plan.Pattern

+ func (rule PushDownReadTagValuesRule) Rewrite(pn plan.Node) (plan.Node, bool, error)

+ type ReadFilterSpec struct

+ Bounds execute.Bounds

+ Database string

+ Predicate *semantic.FunctionExpression

+ RetentionPolicy string

+ type ReadGroupPhysSpec struct

+ AggregateMethod string

+ GroupKeys []string

+ GroupMode flux.GroupMode

+ func (s *ReadGroupPhysSpec) Copy() plan.ProcedureSpec

+ func (s *ReadGroupPhysSpec) Kind() plan.ProcedureKind

+ type ReadGroupSpec struct

+ AggregateMethod string

+ GroupKeys []string

+ GroupMode GroupMode

+ type ReadRangePhysSpec struct

+ Bounds flux.Bounds

+ Bucket string

+ BucketID string

+ Filter *semantic.FunctionExpression

+ FilterSet bool

+ func (s *ReadRangePhysSpec) Copy() plan.ProcedureSpec

+ func (s *ReadRangePhysSpec) Kind() plan.ProcedureKind

+ func (s *ReadRangePhysSpec) LookupDatabase(ctx context.Context, deps Dependencies, a execute.Administration) (string, string, error)

+ func (s *ReadRangePhysSpec) TimeBounds(predecessorBounds *plan.Bounds) *plan.Bounds

+ type ReadTagKeysPhysSpec struct

+ func (s *ReadTagKeysPhysSpec) Copy() plan.ProcedureSpec

+ func (s *ReadTagKeysPhysSpec) Kind() plan.ProcedureKind

+ type ReadTagKeysSpec struct

+ type ReadTagValuesPhysSpec struct

+ TagKey string

+ func (s *ReadTagValuesPhysSpec) Copy() plan.ProcedureSpec

+ func (s *ReadTagValuesPhysSpec) Kind() plan.ProcedureKind

+ type ReadTagValuesSpec struct

+ TagKey string

type Reader

+ ReadFilter func(ctx context.Context, spec ReadFilterSpec, alloc *memory.Allocator) (TableIterator, error)

+ ReadGroup func(ctx context.Context, spec ReadGroupSpec, alloc *memory.Allocator) (TableIterator, error)

+ ReadTagKeys func(ctx context.Context, spec ReadTagKeysSpec, alloc *memory.Allocator) (TableIterator, error)

+ ReadTagValues func(ctx context.Context, spec ReadTagValuesSpec, alloc *memory.Allocator) (TableIterator, error)

+ type Source struct

+ func (s *Source) AddTransformation(t execute.Transformation)

+ func (s *Source) Metadata() flux.Metadata

+ func (s *Source) Run(ctx context.Context)

+ type TableIterator interface

+ Statistics func() cursors.CursorStats

v1.7.7

Jun 26, 2019

v1.7.6

Apr 16, 2019

Changes in this version

+ const FromKind

+ const PhysicalFromKind

+ func InjectBucketDependencies(depsMap execute.Dependencies, deps BucketDependencies) error

+ func InjectFromDependencies(depsMap execute.Dependencies, deps Dependencies) error

+ func NewSource(id execute.DatasetID, r Reader, readSpec ReadSpec, bounds execute.Bounds, ...) execute.Source

+ type Authorizer interface

+ AuthorizeDatabase func(u meta.User, priv influxql.Privilege, database string) error

+ type BucketDependencies struct

+ AuthEnabled bool

+ Authorizer Authorizer

+ MetaClient MetaClient

+ func (d BucketDependencies) Validate() error

+ type BucketsDecoder struct

+ func (bd *BucketsDecoder) Close() error

+ func (bd *BucketsDecoder) Connect() error

+ func (bd *BucketsDecoder) Decode() (flux.Table, error)

+ func (bd *BucketsDecoder) Fetch() (bool, error)

+ type Dependencies struct

+ AuthEnabled bool

+ Authorizer Authorizer

+ MetaClient MetaClient

+ Reader Reader

+ func (d Dependencies) Validate() error

+ type FromConversionRule struct

+ func (FromConversionRule) Name() string

+ func (FromConversionRule) Pattern() plan.Pattern

+ func (FromConversionRule) Rewrite(pn plan.Node) (plan.Node, bool, error)

+ type FromDistinctRule struct

+ func (FromDistinctRule) Name() string

+ func (FromDistinctRule) Pattern() plan.Pattern

+ func (FromDistinctRule) Rewrite(distinctNode plan.Node) (plan.Node, bool, error)

+ type FromKeysRule struct

+ func (FromKeysRule) Name() string

+ func (FromKeysRule) Pattern() plan.Pattern

+ func (FromKeysRule) Rewrite(keysNode plan.Node) (plan.Node, bool, error)

+ type FromOpSpec struct

+ Bucket string

+ BucketID string

+ func (s *FromOpSpec) Kind() flux.OperationKind

+ type FromProcedureSpec struct

+ Bucket string

+ BucketID string

+ func (s *FromProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *FromProcedureSpec) Kind() plan.ProcedureKind

+ func (s FromProcedureSpec) PostPhysicalValidate(id plan.NodeID) error

+ type GroupMode int

+ const GroupModeAll

+ const GroupModeBy

+ const GroupModeDefault

+ const GroupModeExcept

+ const GroupModeNone

+ func ToGroupMode(fluxMode flux.GroupMode) GroupMode

+ type MergeFromFilterRule struct

+ func (MergeFromFilterRule) Name() string

+ func (MergeFromFilterRule) Pattern() plan.Pattern

+ func (MergeFromFilterRule) Rewrite(filterNode plan.Node) (plan.Node, bool, error)

+ type MergeFromGroupRule struct

+ func (MergeFromGroupRule) Name() string

+ func (MergeFromGroupRule) Pattern() plan.Pattern

+ func (MergeFromGroupRule) Rewrite(groupNode plan.Node) (plan.Node, bool, error)

+ type MergeFromRangeRule struct

+ func (rule MergeFromRangeRule) Name() string

+ func (rule MergeFromRangeRule) Pattern() plan.Pattern

+ func (rule MergeFromRangeRule) Rewrite(node plan.Node) (plan.Node, bool, error)

+ type MetaClient interface

+ Database func(name string) *meta.DatabaseInfo

+ Databases func() []meta.DatabaseInfo

+ type PhysicalFromProcedureSpec struct

+ AggregateMethod string

+ AggregateSet bool

+ Bounds flux.Bounds

+ BoundsSet bool

+ Descending bool

+ DescendingSet bool

+ Filter *semantic.FunctionExpression

+ FilterSet bool

+ GroupKeys []string

+ GroupMode flux.GroupMode

+ GroupingSet bool

+ LimitSet bool

+ OrderByTime bool

+ PointsLimit int64

+ SeriesLimit int64

+ SeriesOffset int64

+ Window plan.WindowSpec

+ WindowSet bool

+ func (PhysicalFromProcedureSpec) Kind() plan.ProcedureKind

+ func (s *PhysicalFromProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *PhysicalFromProcedureSpec) TimeBounds(predecessorBounds *plan.Bounds) *plan.Bounds

+ func (s PhysicalFromProcedureSpec) PostPhysicalValidate(id plan.NodeID) error

+ type ReadSpec struct

+ AggregateMethod string

+ Database string

+ Descending bool

+ GroupKeys []string

+ GroupMode GroupMode

+ Hosts []string

+ OrderByTime bool

+ PointsLimit int64

+ Predicate *semantic.FunctionExpression

+ RAMLimit uint64

+ RetentionPolicy string

+ SeriesLimit int64

+ SeriesOffset int64

+ type Reader interface

+ Close func()

+ Read func(ctx context.Context, rs ReadSpec, start, stop execute.Time, ...) (flux.TableIterator, error)

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