influxdb

package
v0.194.1 Latest Latest
Warning

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

 Go to latest Published: Apr 17, 2023 License: MIT Imports: 32 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 (
	DefaultMeasurementColLabel = "_measurement"
	DefaultFieldColLabel       = "_field"
)
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

View Source 
const WideToKind = "wide-to"

Variables

This section is empty.

Functions

func CreateSource added in v0.68.0 

func CreateSource(id execute.DatasetID, spec RemoteProcedureSpec, a execute.Administration) (execute.Source, error)

func NewToTransformation added in v0.117.0 

func NewToTransformation(ctx context.Context, id execute.DatasetID, spec *ToProcedureSpec, deps influxdb.Provider, mem memory.Allocator) (execute.Transformation, execute.Dataset, error)

NewToTransformation returns a new *ToTransformation with the appropriate fields set.

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 (s *BucketsProcedureSpec) Copy() plan.ProcedureSpec

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 (s *BucketsProcedureSpec) Kind() plan.ProcedureKind

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 (s *BucketsRemoteProcedureSpec) Copy() plan.ProcedureSpec

func (*BucketsRemoteProcedureSpec) Kind added in v0.68.0 

func (s *BucketsRemoteProcedureSpec) Kind() plan.ProcedureKind

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 

func (s *CardinalityOpSpec) Kind() flux.OperationKind

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 (s *CardinalityProcedureSpec) Copy() plan.ProcedureSpec

func (*CardinalityProcedureSpec) Kind added in v0.92.0 

func (s *CardinalityProcedureSpec) Kind() plan.ProcedureKind

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 

func (d DefaultFromAttributes) Rewrite(ctx context.Context, n plan.Node) (plan.Node, bool, error)

type Dependency added in v0.125.0 

type Dependency = influxdb.Dependency

type Field added in v0.174.0 

type Field = influxdb.Field

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 (s *FromProcedureSpec) Copy() plan.ProcedureSpec

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 (s *FromProcedureSpec) Kind() plan.ProcedureKind

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 (s *FromRemoteProcedureSpec) Copy() plan.ProcedureSpec

func (*FromRemoteProcedureSpec) Kind added in v0.68.0 

func (s *FromRemoteProcedureSpec) Kind() plan.ProcedureKind

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

type LabelAndOffset struct {
	Label  string
	Offset int
}

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

type Metric = influxdb.Metric

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

type Provider = influxdb.Provider

func GetProvider added in v0.121.0 

func GetProvider(ctx context.Context) Provider

type RemoteProcedureSpec added in v0.68.0 

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

	BuildQuery() *ast.File
}

type RowMetric added in v0.121.0 

type RowMetric struct {
	NameStr string
	Tags    []*influxdb.Tag
	Fields  []*influxdb.Field
	TS      time.Time
}

RowMetric is a Metric

func (RowMetric) FieldList added in v0.121.0 

func (r RowMetric) FieldList() []*influxdb.Field

func (RowMetric) Name added in v0.121.0 

func (r RowMetric) Name() string

func (RowMetric) TagList added in v0.121.0 

func (r RowMetric) TagList() []*influxdb.Tag

func (RowMetric) Time added in v0.121.0 

func (r RowMetric) Time() time.Time

type Tag added in v0.174.0 

type Tag = influxdb.Tag

type ToOpSpec added in v0.117.0 

type ToOpSpec struct {
	Bucket            string                       `json:"bucket"`
	BucketID          string                       `json:"bucketID"`
	Org               string                       `json:"org"`
	OrgID             string                       `json:"orgID"`
	Host              string                       `json:"host"`
	Token             string                       `json:"token"`
	TimeColumn        string                       `json:"timeColumn"`
	MeasurementColumn string                       `json:"measurementColumn"`
	TagColumns        []string                     `json:"tagColumns"`
	FieldFn           interpreter.ResolvedFunction `json:"fieldFn"`
}

ToOpSpec is the flux.OperationSpec for the `to` flux function.

func (ToOpSpec) Kind added in v0.117.0 

func (ToOpSpec) Kind() flux.OperationKind

Kind returns the kind for the ToOpSpec function.

func (*ToOpSpec) ReadArgs added in v0.117.0 

func (o *ToOpSpec) ReadArgs(args flux.Arguments) error

ReadArgs reads the args from flux.Arguments into the op spec

type ToProcedureSpec added in v0.117.0 

type ToProcedureSpec struct {
	plan.DefaultCost
	Spec *ToOpSpec
}

ToProcedureSpec is the procedure spec for the `to` flux function.

func (*ToProcedureSpec) Copy added in v0.117.0 

func (o *ToProcedureSpec) Copy() plan.ProcedureSpec

Copy clones the procedure spec for `to` flux function.

func (*ToProcedureSpec) Kind added in v0.117.0 

func (o *ToProcedureSpec) Kind() plan.ProcedureKind

Kind returns the kind for the procedure spec for the `to` flux function.

func (*ToProcedureSpec) PassThroughAttribute added in v0.175.0 

func (o *ToProcedureSpec) PassThroughAttribute(attrKey string) bool

type UnimplementedProvider added in v0.125.0 

type UnimplementedProvider = influxdb.UnimplementedProvider

type WideToOpSpec added in v0.174.0 

type WideToOpSpec struct {
	Org    NameOrID
	Bucket NameOrID
	Host   string
	Token  string
}

WideToOpSpec is the flux.OperationSpec for the `to` flux function.

func (WideToOpSpec) Kind added in v0.174.0 

func (WideToOpSpec) Kind() flux.OperationKind

Kind returns the kind for the WideToOpSpec function.

func (*WideToOpSpec) ReadArgs added in v0.174.0 

func (s *WideToOpSpec) ReadArgs(args flux.Arguments) error

ReadArgs reads the args from flux.Arguments into the op spec

type WideToProcedureSpec added in v0.174.0 

type WideToProcedureSpec struct {
	plan.DefaultCost
	Config Config
}

WideToProcedureSpec is the procedure spec for the `to` flux function.

func (*WideToProcedureSpec) Copy added in v0.174.0 

func (o *WideToProcedureSpec) Copy() plan.ProcedureSpec

Copy clones the procedure spec for `to` flux function.

func (*WideToProcedureSpec) Kind added in v0.174.0 

func (o *WideToProcedureSpec) Kind() plan.ProcedureKind

Kind returns the kind for the procedure spec for the `to` flux function.

type WideToTransformation added in v0.174.0 

type WideToTransformation struct {
	execute.ExecutionNode
	// contains filtered or unexported fields
}

WideToTransformation is the transformation for the `to` flux function.

func NewWideToTransformation added in v0.174.0 

func NewWideToTransformation(ctx context.Context, d execute.Dataset, cache execute.TableBuilderCache, s *WideToProcedureSpec) (*WideToTransformation, error)

NewWideToTransformation returns a new *WideToTransformation with the appropriate fields set.

func (*WideToTransformation) Finish added in v0.174.0 

func (t *WideToTransformation) Finish(id execute.DatasetID, err error)

Finish is called after the `to` flux function's transformation is done processing.

func (*WideToTransformation) Process added in v0.174.0 

func (t *WideToTransformation) Process(id execute.DatasetID, tbl flux.Table) error

Process does the actual work for the WideToTransformation.

func (*WideToTransformation) RetractTable added in v0.174.0 

func (t *WideToTransformation) RetractTable(id execute.DatasetID, key flux.GroupKey) error

RetractTable retracts the table for the transformation for the `to` flux function.

func (*WideToTransformation) UpdateProcessingTime added in v0.174.0 

func (t *WideToTransformation) UpdateProcessingTime(id execute.DatasetID, pt execute.Time) error

UpdateProcessingTime updates the processing time for the transformation for the `to` flux function.

func (*WideToTransformation) UpdateWatermark added in v0.174.0 

func (t *WideToTransformation) UpdateWatermark(id execute.DatasetID, pt execute.Time) error

UpdateWatermark updates the watermark for the transformation for the `to` flux function.

type Writer added in v0.121.0 

type Writer = influxdb.Writer

Source Files

View all Source files

Directories

Path Synopsis
internal
testutil

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.