Documentation ¶
Overview ¶
Package influxdb implements the standard library functions for interacting with influxdb. It uses the influxdb dependency from the dependencies/influxdb package to implement the builtins.
Index ¶
- Constants
- Variables
- func CreateSource(id execute.DatasetID, spec RemoteProcedureSpec, a execute.Administration) (execute.Source, error)
- type BucketsOpSpec
- type BucketsProcedureSpec
- func (s *BucketsProcedureSpec) Copy() plan.ProcedureSpec
- func (s *BucketsProcedureSpec) GetHost() *string
- func (s *BucketsProcedureSpec) GetOrg() *NameOrID
- func (s *BucketsProcedureSpec) GetToken() *string
- func (s *BucketsProcedureSpec) Kind() plan.ProcedureKind
- func (s *BucketsProcedureSpec) PostPhysicalValidate(id plan.NodeID) error
- func (s *BucketsProcedureSpec) SetHost(host *string)
- func (s *BucketsProcedureSpec) SetOrg(org *NameOrID)
- func (s *BucketsProcedureSpec) SetToken(token *string)
- type BucketsRemoteProcedureSpec
- type BucketsRemoteRule
- type CardinalityOpSpec
- type CardinalityProcedureSpec
- type Config
- type DefaultFromAttributes
- type FromOpSpec
- type FromProcedureSpec
- func (s *FromProcedureSpec) Copy() plan.ProcedureSpec
- func (s *FromProcedureSpec) GetHost() *string
- func (s *FromProcedureSpec) GetOrg() *NameOrID
- func (s *FromProcedureSpec) GetToken() *string
- func (s *FromProcedureSpec) Kind() plan.ProcedureKind
- func (s *FromProcedureSpec) PostPhysicalValidate(id plan.NodeID) error
- func (s *FromProcedureSpec) SetHost(host *string)
- func (s *FromProcedureSpec) SetOrg(org *NameOrID)
- func (s *FromProcedureSpec) SetToken(token *string)
- type FromRemoteProcedureSpec
- type FromRemoteRule
- type MergeRemoteFilterRule
- type MergeRemoteRangeRule
- type NameOrID
- type Predicate
- type PredicateSet
- type ProcedureSpec
- type RemoteProcedureSpec
Constants ¶
const ( BucketsKind = "buckets" BucketsRemoteKind = "influxdata/influxdb.bucketsRemote" )
const ( CardinalityFuncName = "cardinality" CardinalityKind = PackageName + "." + CardinalityFuncName )
const ( PackageName = "influxdata/influxdb" FromKind = "from" FromRemoteKind = "influxdata/influxdb.fromRemote" )
const ToKind = "to"
ToKind is the kind for the `to` flux function
Variables ¶
var ToSignature = runtime.MustLookupBuiltinType("influxdata/influxdb", "to")
Functions ¶
func CreateSource ¶
func CreateSource(id execute.DatasetID, spec RemoteProcedureSpec, a execute.Administration) (execute.Source, error)
Types ¶
type BucketsOpSpec ¶
func (*BucketsOpSpec) Kind ¶
func (s *BucketsOpSpec) Kind() flux.OperationKind
type BucketsProcedureSpec ¶
type BucketsProcedureSpec struct { plan.DefaultCost Org *NameOrID Host *string Token *string }
func (*BucketsProcedureSpec) Copy ¶
func (s *BucketsProcedureSpec) Copy() plan.ProcedureSpec
func (*BucketsProcedureSpec) GetHost ¶
func (s *BucketsProcedureSpec) GetHost() *string
func (*BucketsProcedureSpec) GetOrg ¶
func (s *BucketsProcedureSpec) GetOrg() *NameOrID
func (*BucketsProcedureSpec) GetToken ¶
func (s *BucketsProcedureSpec) GetToken() *string
func (*BucketsProcedureSpec) Kind ¶
func (s *BucketsProcedureSpec) Kind() plan.ProcedureKind
func (*BucketsProcedureSpec) PostPhysicalValidate ¶
func (s *BucketsProcedureSpec) PostPhysicalValidate(id plan.NodeID) error
func (*BucketsProcedureSpec) SetHost ¶
func (s *BucketsProcedureSpec) SetHost(host *string)
func (*BucketsProcedureSpec) SetOrg ¶
func (s *BucketsProcedureSpec) SetOrg(org *NameOrID)
func (*BucketsProcedureSpec) SetToken ¶
func (s *BucketsProcedureSpec) SetToken(token *string)
type BucketsRemoteProcedureSpec ¶
type BucketsRemoteProcedureSpec struct { plan.DefaultCost *BucketsProcedureSpec }
func (*BucketsRemoteProcedureSpec) BuildQuery ¶
func (s *BucketsRemoteProcedureSpec) BuildQuery() *ast.File
func (*BucketsRemoteProcedureSpec) Copy ¶
func (s *BucketsRemoteProcedureSpec) Copy() plan.ProcedureSpec
func (*BucketsRemoteProcedureSpec) Kind ¶
func (s *BucketsRemoteProcedureSpec) Kind() plan.ProcedureKind
func (*BucketsRemoteProcedureSpec) PostPhysicalValidate ¶
func (s *BucketsRemoteProcedureSpec) PostPhysicalValidate(id plan.NodeID) error
type BucketsRemoteRule ¶
type BucketsRemoteRule struct{}
func (BucketsRemoteRule) Name ¶
func (p BucketsRemoteRule) Name() string
func (BucketsRemoteRule) Pattern ¶
func (p BucketsRemoteRule) Pattern() plan.Pattern
type CardinalityOpSpec ¶
type CardinalityOpSpec struct { influxdb.Config Start flux.Time Stop flux.Time Predicate influxdb.Predicate }
func (*CardinalityOpSpec) Kind ¶
func (s *CardinalityOpSpec) Kind() flux.OperationKind
type CardinalityProcedureSpec ¶
type CardinalityProcedureSpec struct { plan.DefaultCost influxdb.Config Bounds flux.Bounds PredicateSet influxdb.PredicateSet }
func (*CardinalityProcedureSpec) Copy ¶
func (s *CardinalityProcedureSpec) Copy() plan.ProcedureSpec
func (*CardinalityProcedureSpec) Kind ¶
func (s *CardinalityProcedureSpec) Kind() plan.ProcedureKind
func (*CardinalityProcedureSpec) TimeBounds ¶
func (s *CardinalityProcedureSpec) TimeBounds(predecessorBounds *plan.Bounds) *plan.Bounds
TimeBounds implements plan.BoundsAwareProcedureSpec
type DefaultFromAttributes ¶
DefaultFromAttributes is used to inject default attributes for the various from attributes.
This rule is not added by default. Each process must fill out the suitable defaults and add the rule on startup.
func (DefaultFromAttributes) Name ¶
func (d DefaultFromAttributes) Name() string
func (DefaultFromAttributes) Pattern ¶
func (d DefaultFromAttributes) Pattern() plan.Pattern
type FromOpSpec ¶
func (*FromOpSpec) Kind ¶
func (s *FromOpSpec) Kind() flux.OperationKind
type FromProcedureSpec ¶
type FromProcedureSpec struct { plan.DefaultCost Org *NameOrID Bucket NameOrID Host *string Token *string }
func (*FromProcedureSpec) Copy ¶
func (s *FromProcedureSpec) Copy() plan.ProcedureSpec
func (*FromProcedureSpec) GetHost ¶
func (s *FromProcedureSpec) GetHost() *string
func (*FromProcedureSpec) GetOrg ¶
func (s *FromProcedureSpec) GetOrg() *NameOrID
func (*FromProcedureSpec) GetToken ¶
func (s *FromProcedureSpec) GetToken() *string
func (*FromProcedureSpec) Kind ¶
func (s *FromProcedureSpec) Kind() plan.ProcedureKind
func (*FromProcedureSpec) PostPhysicalValidate ¶
func (s *FromProcedureSpec) PostPhysicalValidate(id plan.NodeID) error
func (*FromProcedureSpec) SetHost ¶
func (s *FromProcedureSpec) SetHost(host *string)
func (*FromProcedureSpec) SetOrg ¶
func (s *FromProcedureSpec) SetOrg(org *NameOrID)
func (*FromProcedureSpec) SetToken ¶
func (s *FromProcedureSpec) SetToken(token *string)
type FromRemoteProcedureSpec ¶
type FromRemoteProcedureSpec struct { plan.DefaultCost influxdb.Config Bounds flux.Bounds PredicateSet influxdb.PredicateSet }
func (*FromRemoteProcedureSpec) Copy ¶
func (s *FromRemoteProcedureSpec) Copy() plan.ProcedureSpec
func (*FromRemoteProcedureSpec) Kind ¶
func (s *FromRemoteProcedureSpec) Kind() plan.ProcedureKind
func (*FromRemoteProcedureSpec) PostPhysicalValidate ¶
func (s *FromRemoteProcedureSpec) PostPhysicalValidate(id plan.NodeID) error
func (*FromRemoteProcedureSpec) TimeBounds ¶
func (s *FromRemoteProcedureSpec) TimeBounds(predecessorBounds *plan.Bounds) *plan.Bounds
TimeBounds implements plan.BoundsAwareProcedureSpec
type FromRemoteRule ¶
type FromRemoteRule struct{}
func (FromRemoteRule) Name ¶
func (p FromRemoteRule) Name() string
func (FromRemoteRule) Pattern ¶
func (p FromRemoteRule) Pattern() plan.Pattern
type MergeRemoteFilterRule ¶
type MergeRemoteFilterRule struct{}
func (MergeRemoteFilterRule) Name ¶
func (p MergeRemoteFilterRule) Name() string
func (MergeRemoteFilterRule) Pattern ¶
func (p MergeRemoteFilterRule) Pattern() plan.Pattern
type MergeRemoteRangeRule ¶
type MergeRemoteRangeRule struct{}
func (MergeRemoteRangeRule) Name ¶
func (p MergeRemoteRangeRule) Name() string
func (MergeRemoteRangeRule) Pattern ¶
func (p MergeRemoteRangeRule) Pattern() plan.Pattern
type NameOrID ¶
NameOrID signifies the name of an organization/bucket or an ID for an organization/bucket.
type PredicateSet ¶
type PredicateSet = influxdb.PredicateSet
PredicateSet holds a set of predicates that will filter the results.