inputs

package
v1.5.1-0...-4d21ab9 Latest Latest
Warning

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

Go to latest
Published: Jan 7, 2019 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func InjectBucketDependencies

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

func InjectFromDependencies

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

Types

type Authorizer

type Authorizer interface {
	AuthorizeDatabase(u meta.User, priv influxql.Privilege, database string) error
}

type BucketDependencies

type BucketDependencies struct {
	MetaClient  MetaClient
	Authorizer  Authorizer
	AuthEnabled bool
}

func (BucketDependencies) Validate

func (d BucketDependencies) Validate() error

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 Dependencies

type Dependencies struct {
	Reader      storage.Reader
	MetaClient  MetaClient
	Authorizer  Authorizer
	AuthEnabled bool
}

func (Dependencies) Validate

func (d Dependencies) Validate() error

type MetaClient

type MetaClient interface {
	Databases() []meta.DatabaseInfo
	Database(name string) *meta.DatabaseInfo
}

Jump to

Keyboard shortcuts

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