influxdb

package

Go to main page

Versions in this module

v0

v0.99.12

Apr 13, 2020

v0.99.11

Apr 13, 2020

Changes in this version

+ const BucketsRemoteKind

+ const FromRemoteKind

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

type BucketsOpSpec

+ Host *string

+ Org *NameOrID

+ Token *string

type BucketsProcedureSpec

+ Host *string

+ Org *NameOrID

+ Token *string

+ func (s *BucketsProcedureSpec) GetHost() *string

+ func (s *BucketsProcedureSpec) GetOrg() *NameOrID

+ func (s *BucketsProcedureSpec) GetToken() *string

+ 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 struct

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

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

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

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

+ type BucketsRemoteRule struct

+ func (p BucketsRemoteRule) Name() string

+ func (p BucketsRemoteRule) Pattern() plan.Pattern

+ func (p BucketsRemoteRule) Rewrite(node plan.Node) (plan.Node, bool, error)

+ type DefaultFromAttributes struct

+ Host *string

+ Org *NameOrID

+ Token *string

+ func (d DefaultFromAttributes) Name() string

+ func (d DefaultFromAttributes) Pattern() plan.Pattern

+ func (d DefaultFromAttributes) Rewrite(n plan.Node) (plan.Node, bool, error)

type FromOpSpec

+ Host *string

+ Org *NameOrID

+ Token *string

type FromProcedureSpec

+ Host *string

+ Org *NameOrID

+ Token *string

+ func (s *FromProcedureSpec) GetHost() *string

+ func (s *FromProcedureSpec) GetOrg() *NameOrID

+ func (s *FromProcedureSpec) GetToken() *string

+ 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 struct

+ Range *universe.RangeProcedureSpec

+ Transformations []plan.ProcedureSpec

+ func (s *FromRemoteProcedureSpec) BuildQuery() *ast.File

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

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

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

+ type FromRemoteRule struct

+ func (p FromRemoteRule) Name() string

+ func (p FromRemoteRule) Pattern() plan.Pattern

+ func (p FromRemoteRule) Rewrite(node plan.Node) (plan.Node, bool, error)

+ type MergeRemoteFilterRule struct

+ func (p MergeRemoteFilterRule) Name() string

+ func (p MergeRemoteFilterRule) Pattern() plan.Pattern

+ func (p MergeRemoteFilterRule) Rewrite(node plan.Node) (plan.Node, bool, error)

+ type MergeRemoteRangeRule struct

+ func (p MergeRemoteRangeRule) Name() string

+ func (p MergeRemoteRangeRule) Pattern() plan.Pattern

+ func (p MergeRemoteRangeRule) Rewrite(node plan.Node) (plan.Node, bool, error)

+ type NameOrID struct

+ ID string

+ Name string

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

+ type ProcedureSpec interface

+ GetHost func() *string

+ GetOrg func() *NameOrID

+ GetToken func() *string

+ SetHost func(host *string)

+ SetOrg func(org *NameOrID)

+ SetToken func(token *string)

+ type RemoteProcedureSpec interface

+ BuildQuery func() *ast.File

+ GetHost func() *string

+ GetOrg func() *NameOrID

+ GetToken func() *string

v0.99.2

Apr 10, 2020

v0.99.1

Apr 10, 2020

Changes in this version

+ const BucketsKind

+ const FromKind

+ const ToKind

+ var ToSignature = flux.FunctionSignature(map[string]semantic.PolyType{ ... }, []string{})

+ type BucketsOpSpec struct

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

+ type BucketsProcedureSpec struct

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

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

+ type FromOpSpec struct

+ Bucket string

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

+ type FromProcedureSpec struct

+ Bucket string

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

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

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