inputs

Documentation

Index

• func InjectBucketDependencies(depsMap execute.Dependencies, deps BucketDependencies) error
• func InjectFromDependencies(depsMap execute.Dependencies, deps Dependencies) error
• type BucketDependencies
• 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 BucketDependencies

type BucketDependencies MetaClient

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
}

func (Dependencies) Validate

func (d Dependencies) Validate() error

type MetaClient

type MetaClient interface {
	Databases() []meta.DatabaseInfo
}