retry

Documentation

Index

• type Retry
• type TaskRetry

Types

type Retry

type Retry interface {
	AddPolicy(policy *task.TimeRetry, mesosTask *mesos_v1.TaskInfo) error
	CheckPolicy(mesosTask *mesos_v1.TaskInfo) *TaskRetry
	ClearPolicy(mesosTask *mesos_v1.TaskInfo) error
	RunPolicy(policy *TaskRetry, f func() error) error
}

Provides pluggable retry mechanisms. Also used extensively for testing with mocks.

type TaskRetry

type TaskRetry struct {
	TotalRetries int
	MaxRetries   int
	RetryTime    time.Duration
	Backoff      bool
	Name         string
}

Primary retry mechanism used with policies in the task manager and persistence engine.