inputs

package
v0.0.0-...-d500d3c Latest Latest
Warning

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

Go to latest
Published: Jan 17, 2019 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source
const DatabasesKind = "databases"

Variables

This section is empty.

Functions

func InjectBucketDependencies

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

func InjectDatabasesDependencies

func InjectDatabasesDependencies(depsMap execute.Dependencies, deps DatabasesDependencies) error

func InjectFromDependencies

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

Types

type AllBucketLookup

type AllBucketLookup interface {
	FindAllBuckets(orgID platform.ID) ([]*platform.Bucket, int)
}

type BucketDependencies

type BucketDependencies AllBucketLookup

type BucketsDecoder

type BucketsDecoder struct {
	// contains filtered or unexported fields
}

func (*BucketsDecoder) Connect

func (bd *BucketsDecoder) Connect() error

func (*BucketsDecoder) Decode

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

func (*BucketsDecoder) Fetch

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

type DatabasesDecoder

type DatabasesDecoder struct {
	// contains filtered or unexported fields
}

func (*DatabasesDecoder) Connect

func (bd *DatabasesDecoder) Connect() error

func (*DatabasesDecoder) Decode

func (bd *DatabasesDecoder) Decode() (flux.Table, error)

func (*DatabasesDecoder) Fetch

func (bd *DatabasesDecoder) Fetch() (bool, error)

type DatabasesDependencies

type DatabasesDependencies struct {
	DBRP         platform.DBRPMappingService
	BucketLookup platform.BucketService
}

type DatabasesOpSpec

type DatabasesOpSpec struct {
}

func (*DatabasesOpSpec) Kind

type DatabasesProcedureSpec

type DatabasesProcedureSpec struct {
	plan.DefaultCost
}

func (*DatabasesProcedureSpec) Copy

func (*DatabasesProcedureSpec) Kind

Directories

Path Synopsis
Package storage implements reading from a storage engine into a table as a data source.
Package storage implements reading from a storage engine into a table as a data source.

Jump to

Keyboard shortcuts

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