inputs

Documentation

Index

• func InjectBucketDependencies(depsMap execute.Dependencies, deps BucketDependencies) error
• func InjectFromDependencies(depsMap execute.Dependencies, deps Dependencies) error
• type Authorizer
• type BucketDependencies
  • func (d BucketDependencies) Validate() error
• type BucketsDecoder
  • func (bd *BucketsDecoder) Connect() error
  • func (bd *BucketsDecoder) Decode() (flux.Table, error)
  • func (bd *BucketsDecoder) Fetch() (bool, error)
• type Dependencies
  • func (d Dependencies) Validate() error
• type MetaClient

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
}