influxdb

package
v0.101.0 Latest Latest
Warning

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

Go to latest
Published: Jan 15, 2021 License: MIT Imports: 20 Imported by: 5

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

View Source
const (
	BucketsKind       = "buckets"
	BucketsRemoteKind = "influxdata/influxdb.bucketsRemote"
)
View Source
const (
	CardinalityFuncName = "cardinality"
	CardinalityKind     = PackageName + "." + CardinalityFuncName
)
View Source
const (
	PackageName    = "influxdata/influxdb"
	FromKind       = "from"
	FromRemoteKind = "influxdata/influxdb.fromRemote"
)
View Source
const ToKind = "to"

ToKind is the kind for the `to` flux function

Variables

View Source
var ToSignature = runtime.MustLookupBuiltinType("influxdata/influxdb", "to")

Functions

func CreateSource added in v0.68.0

Types

type BucketsOpSpec

type BucketsOpSpec struct {
	Org   *NameOrID
	Host  *string
	Token *string
}

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 (*BucketsProcedureSpec) GetHost added in v0.68.0

func (s *BucketsProcedureSpec) GetHost() *string

func (*BucketsProcedureSpec) GetOrg added in v0.68.0

func (s *BucketsProcedureSpec) GetOrg() *NameOrID

func (*BucketsProcedureSpec) GetToken added in v0.68.0

func (s *BucketsProcedureSpec) GetToken() *string

func (*BucketsProcedureSpec) Kind

func (*BucketsProcedureSpec) PostPhysicalValidate added in v0.68.0

func (s *BucketsProcedureSpec) PostPhysicalValidate(id plan.NodeID) error

func (*BucketsProcedureSpec) SetHost added in v0.68.0

func (s *BucketsProcedureSpec) SetHost(host *string)

func (*BucketsProcedureSpec) SetOrg added in v0.68.0

func (s *BucketsProcedureSpec) SetOrg(org *NameOrID)

func (*BucketsProcedureSpec) SetToken added in v0.68.0

func (s *BucketsProcedureSpec) SetToken(token *string)

type BucketsRemoteProcedureSpec added in v0.68.0

type BucketsRemoteProcedureSpec struct {
	plan.DefaultCost
	*BucketsProcedureSpec
}

func (*BucketsRemoteProcedureSpec) BuildQuery added in v0.68.0

func (s *BucketsRemoteProcedureSpec) BuildQuery() *ast.File

func (*BucketsRemoteProcedureSpec) Copy added in v0.68.0

func (*BucketsRemoteProcedureSpec) Kind added in v0.68.0

func (*BucketsRemoteProcedureSpec) PostPhysicalValidate added in v0.68.0

func (s *BucketsRemoteProcedureSpec) PostPhysicalValidate(id plan.NodeID) error

type BucketsRemoteRule added in v0.68.0

type BucketsRemoteRule struct{}

func (BucketsRemoteRule) Name added in v0.68.0

func (p BucketsRemoteRule) Name() string

func (BucketsRemoteRule) Pattern added in v0.68.0

func (p BucketsRemoteRule) Pattern() plan.Pattern

func (BucketsRemoteRule) Rewrite added in v0.68.0

func (p BucketsRemoteRule) Rewrite(ctx context.Context, node plan.Node) (plan.Node, bool, error)

type CardinalityOpSpec added in v0.92.0

type CardinalityOpSpec struct {
	influxdb.Config
	Start     flux.Time
	Stop      flux.Time
	Predicate influxdb.Predicate
}

func (*CardinalityOpSpec) Kind added in v0.92.0

type CardinalityProcedureSpec added in v0.92.0

type CardinalityProcedureSpec struct {
	plan.DefaultCost
	influxdb.Config
	Bounds       flux.Bounds
	PredicateSet influxdb.PredicateSet
}

func (*CardinalityProcedureSpec) Copy added in v0.92.0

func (*CardinalityProcedureSpec) Kind added in v0.92.0

func (*CardinalityProcedureSpec) TimeBounds added in v0.92.0

func (s *CardinalityProcedureSpec) TimeBounds(predecessorBounds *plan.Bounds) *plan.Bounds

TimeBounds implements plan.BoundsAwareProcedureSpec

type Config added in v0.92.0

type Config = influxdb.Config

Config contains the common configuration for interacting with an influxdb instance.

type DefaultFromAttributes added in v0.68.0

type DefaultFromAttributes struct {
	Org   *NameOrID
	Host  *string
	Token *string
}

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 added in v0.68.0

func (d DefaultFromAttributes) Name() string

func (DefaultFromAttributes) Pattern added in v0.68.0

func (d DefaultFromAttributes) Pattern() plan.Pattern

func (DefaultFromAttributes) Rewrite added in v0.68.0

type FromOpSpec

type FromOpSpec struct {
	Org    *NameOrID
	Bucket NameOrID
	Host   *string
	Token  *string
}

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 (*FromProcedureSpec) GetHost added in v0.68.0

func (s *FromProcedureSpec) GetHost() *string

func (*FromProcedureSpec) GetOrg added in v0.68.0

func (s *FromProcedureSpec) GetOrg() *NameOrID

func (*FromProcedureSpec) GetToken added in v0.68.0

func (s *FromProcedureSpec) GetToken() *string

func (*FromProcedureSpec) Kind

func (*FromProcedureSpec) PostPhysicalValidate

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

func (*FromProcedureSpec) SetHost added in v0.68.0

func (s *FromProcedureSpec) SetHost(host *string)

func (*FromProcedureSpec) SetOrg added in v0.68.0

func (s *FromProcedureSpec) SetOrg(org *NameOrID)

func (*FromProcedureSpec) SetToken added in v0.68.0

func (s *FromProcedureSpec) SetToken(token *string)

type FromRemoteProcedureSpec added in v0.68.0

type FromRemoteProcedureSpec struct {
	plan.DefaultCost
	influxdb.Config
	Bounds       flux.Bounds
	PredicateSet influxdb.PredicateSet
}

func (*FromRemoteProcedureSpec) Copy added in v0.68.0

func (*FromRemoteProcedureSpec) Kind added in v0.68.0

func (*FromRemoteProcedureSpec) PostPhysicalValidate added in v0.68.0

func (s *FromRemoteProcedureSpec) PostPhysicalValidate(id plan.NodeID) error

func (*FromRemoteProcedureSpec) TimeBounds added in v0.68.0

func (s *FromRemoteProcedureSpec) TimeBounds(predecessorBounds *plan.Bounds) *plan.Bounds

TimeBounds implements plan.BoundsAwareProcedureSpec

type FromRemoteRule added in v0.68.0

type FromRemoteRule struct{}

func (FromRemoteRule) Name added in v0.68.0

func (p FromRemoteRule) Name() string

func (FromRemoteRule) Pattern added in v0.68.0

func (p FromRemoteRule) Pattern() plan.Pattern

func (FromRemoteRule) Rewrite added in v0.68.0

func (p FromRemoteRule) Rewrite(ctx context.Context, node plan.Node) (plan.Node, bool, error)

type MergeRemoteFilterRule added in v0.68.0

type MergeRemoteFilterRule struct{}

func (MergeRemoteFilterRule) Name added in v0.68.0

func (p MergeRemoteFilterRule) Name() string

func (MergeRemoteFilterRule) Pattern added in v0.68.0

func (p MergeRemoteFilterRule) Pattern() plan.Pattern

func (MergeRemoteFilterRule) Rewrite added in v0.68.0

func (p MergeRemoteFilterRule) Rewrite(ctx context.Context, node plan.Node) (plan.Node, bool, error)

type MergeRemoteRangeRule added in v0.68.0

type MergeRemoteRangeRule struct{}

func (MergeRemoteRangeRule) Name added in v0.68.0

func (p MergeRemoteRangeRule) Name() string

func (MergeRemoteRangeRule) Pattern added in v0.68.0

func (p MergeRemoteRangeRule) Pattern() plan.Pattern

func (MergeRemoteRangeRule) Rewrite added in v0.68.0

func (p MergeRemoteRangeRule) Rewrite(ctx context.Context, node plan.Node) (plan.Node, bool, error)

type NameOrID added in v0.68.0

type NameOrID = influxdb.NameOrID

NameOrID signifies the name of an organization/bucket or an ID for an organization/bucket.

func GetNameOrID added in v0.68.0

func GetNameOrID(args flux.Arguments, nameParam, idParam string) (NameOrID, bool, error)

type Predicate added in v0.92.0

type Predicate = influxdb.Predicate

Predicate defines a predicate to filter storage with.

type PredicateSet added in v0.92.0

type PredicateSet = influxdb.PredicateSet

PredicateSet holds a set of predicates that will filter the results.

type ProcedureSpec added in v0.68.0

type ProcedureSpec interface {
	GetOrg() *NameOrID
	GetHost() *string
	GetToken() *string
	SetOrg(org *NameOrID)
	SetHost(host *string)
	SetToken(token *string)
}

type RemoteProcedureSpec added in v0.68.0

type RemoteProcedureSpec interface {
	GetOrg() *NameOrID
	GetHost() *string
	GetToken() *string

	BuildQuery() *ast.File
}

Directories

Path Synopsis
internal

Jump to

Keyboard shortcuts

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