Documentation
¶
Index ¶
- Constants
- Variables
- func CronUpdate(jobs []*types.RecurringJob) types.Event
- func Monitor(getController types.GetController) types.BeginMonitoring
- func New(orc types.Orchestrator, monitor types.BeginMonitoring, ...) types.VolumeManager
- func NewControllerError(err error) error
- func RunJobs(volume *types.VolumeInfo, ctrl types.Controller, settings types.Settings, ...)
- func Send(c chan<- types.Event, e types.Event) bool
- func TimeEvent() types.Event
- func ValidateJobs(jobs []*types.RecurringJob) error
- type ControllerError
- type Errs
- type Task
- type Ticker
Constants ¶
View Source
const ( JobName = "job" BackupJob = "backupJob" )
Variables ¶
View Source
var ( MonitoringPeriod = time.Second * 2 MonitoringMaxRetries = 3 CleanupPeriod = time.Minute * 2 )
View Source
var (
KeepBadReplicasPeriod = time.Hour * 2
)
Functions ¶
func CronUpdate ¶
func CronUpdate(jobs []*types.RecurringJob) types.Event
func Monitor ¶
func Monitor(getController types.GetController) types.BeginMonitoring
func New ¶
func New(orc types.Orchestrator, monitor types.BeginMonitoring, getController types.GetController, getBackups types.GetManagerBackupOps) types.VolumeManager
func NewControllerError ¶
func RunJobs ¶
func RunJobs(volume *types.VolumeInfo, ctrl types.Controller, settings types.Settings, ch chan types.Event)
func ValidateJobs ¶
func ValidateJobs(jobs []*types.RecurringJob) error
Types ¶
type ControllerError ¶
type ControllerError interface {
Cause() error
}
type Task ¶
type Task interface {
Run() error
}
func BackupTask ¶
func BackupTask(runner *jobRunner, job *types.RecurringJob, si *types.SettingsInfo) Task
func SnapshotTask ¶
func SnapshotTask(runner *jobRunner, job *types.RecurringJob, _ *types.SettingsInfo) Task
Source Files
Click to show internal directories.
Click to hide internal directories.