Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // ErrDoneForNow indicates a temporary issue was encountered and // that the worker should restart and retry. ErrDoneForNow = errors.New("done for now") )
Functions ¶
func Manifold ¶
func Manifold(config ManifoldConfig) dependency.Manifold
Manifold packages a Worker for use in a dependency.Engine.
Types ¶
type Facade ¶
type Facade interface {
// Watch returns a watcher which reports when a migration is
// active for the model associated with the API connection.
Watch() (watcher.NotifyWatcher, error)
// GetMigrationStatus returns the details and progress of the
// latest model migration.
GetMigrationStatus() (migrationmaster.MigrationStatus, error)
// SetPhase updates the phase of the currently active model
// migration.
SetPhase(migration.Phase) error
// Export returns a serialized representation of the model
// associated with the API connection.
Export() ([]byte, error)
}
Facade exposes controller functionality to a Worker.
type ManifoldConfig ¶
type ManifoldConfig struct {
APICallerName string
FortressName string
NewFacade func(base.APICaller) (Facade, error)
NewWorker func(Config) (worker.Worker, error)
}
ManifoldConfig defines the names of the manifolds on which a Worker manifold will depend.
Click to show internal directories.
Click to hide internal directories.