inputs

Documentation

Index

• Constants
• func InjectBucketDependencies(depsMap execute.Dependencies, deps BucketDependencies) error
• func InjectDatabasesDependencies(depsMap execute.Dependencies, deps DatabasesDependencies) error
• func InjectFromDependencies(depsMap execute.Dependencies, deps storage.Dependencies) error
• type AllBucketLookup
• type BucketDependencies
• type BucketsDecoder
  • func (bd *BucketsDecoder) Connect() error
  • func (bd *BucketsDecoder) Decode() (flux.Table, error)
  • func (bd *BucketsDecoder) Fetch() (bool, error)
• type DatabasesDecoder
  • func (bd *DatabasesDecoder) Connect() error
  • func (bd *DatabasesDecoder) Decode() (flux.Table, error)
  • func (bd *DatabasesDecoder) Fetch() (bool, error)
• type DatabasesDependencies
• type DatabasesOpSpec
  • func (s *DatabasesOpSpec) Kind() flux.OperationKind
• type DatabasesProcedureSpec
  • func (s *DatabasesProcedureSpec) Copy() plan.ProcedureSpec
  • func (s *DatabasesProcedureSpec) Kind() plan.ProcedureKind

Constants

const DatabasesKind = "databases"

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

func (s *DatabasesOpSpec) Kind() flux.OperationKind

type DatabasesProcedureSpec

type DatabasesProcedureSpec struct {
	plan.DefaultCost
}

func (*DatabasesProcedureSpec) Copy

func (s *DatabasesProcedureSpec) Copy() plan.ProcedureSpec

func (*DatabasesProcedureSpec) Kind

func (s *DatabasesProcedureSpec) Kind() plan.ProcedureKind