restorewatcher

type Config ¶

type Config struct {
	RestoreInfoWatcher RestoreInfoWatcher
}

Config holds the worker configuration.

func (config Config) Validate() error

type ManifoldConfig ¶

type ManifoldConfig struct {
	StateName string
	NewWorker func(Config) (RestoreStatusWorker, error)
}

ManifoldConfig holds the information necessary to run a restorewatcher in a dependency.Engine.

func (config ManifoldConfig) Validate() error

type RestoreInfoWatcher ¶

type RestoreInfoWatcher interface {
	WatchRestoreInfoChanges() state.NotifyWatcher
	RestoreStatus() (state.RestoreStatus, error)
}

RestoreInfoWatcher is an interface for watching and obtaining the restore info/status.

type RestoreInfoWatcherShim ¶

type RestoreInfoWatcherShim struct {
	*state.State
}

func (r RestoreInfoWatcherShim) RestoreStatus() (state.RestoreStatus, error)

type RestoreStatusWorker ¶

type RestoreStatusWorker interface {
	worker.Worker

	// RestoreStatus returns the most recently observed restore status.
	RestoreStatus() state.RestoreStatus
}

RestoreStatusWorker is a worker that provides a means of observing the restore status.

func NewWorker(config Config) (RestoreStatusWorker, error)