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 BucketDependencies ¶
type BucketDependencies MetaClient
type BucketsDecoder ¶
type BucketsDecoder struct {
// contains filtered or unexported fields
}
func (*BucketsDecoder) Connect ¶
func (bd *BucketsDecoder) Connect() error
func (*BucketsDecoder) Fetch ¶
func (bd *BucketsDecoder) Fetch() (bool, error)
type Dependencies ¶
type Dependencies struct {
Reader storage.Reader
MetaClient MetaClient
}
func (Dependencies) Validate ¶
func (d Dependencies) Validate() error
type MetaClient ¶
type MetaClient interface {
Databases() []meta.DatabaseInfo
Database(name string) *meta.DatabaseInfo
}
Source Files
Click to show internal directories.
Click to hide internal directories.