Versions in this module Expand all Collapse all v0 v0.1.3 Aug 26, 2019 v0.1.2 Apr 9, 2019 Changes in this version type Task + func (t *Task) Tags() map[string]string v0.1.0 Feb 23, 2019 Changes in this version + type Executor struct + func NewExecutor(stats tally.Scope, originCluster blobclient.ClusterClient, ...) *Executor + func (e *Executor) Exec(r persistedretry.Task) error + func (e *Executor) Name() string + type Remote struct + type RemoteValidator interface + Valid func(tag, addr string) bool + type Remotes []*Remote + func (rs Remotes) Match(tag string) (addrs []string) + func (rs Remotes) Valid(tag, addr string) bool + type RemotesConfig map[string][]string + func (c RemotesConfig) Build() (Remotes, error) + type Store struct + func NewStore(db *sqlx.DB, rv RemoteValidator) (*Store, error) + func (s *Store) AddFailed(r persistedretry.Task) error + func (s *Store) AddPending(r persistedretry.Task) error + func (s *Store) Find(query interface{}) ([]persistedretry.Task, error) + func (s *Store) GetFailed() ([]persistedretry.Task, error) + func (s *Store) GetPending() ([]persistedretry.Task, error) + func (s *Store) MarkFailed(r persistedretry.Task) error + func (s *Store) MarkPending(r persistedretry.Task) error + func (s *Store) Remove(r persistedretry.Task) error + type Task struct + CreatedAt time.Time + Delay time.Duration + Dependencies core.DigestList + Destination string + Digest core.Digest + Failures int + LastAttempt time.Time + Tag string + func NewTask(tag string, d core.Digest, dependencies core.DigestList, destination string, ...) *Task + func TaskFixture() *Task + func (t *Task) GetFailures() int + func (t *Task) GetLastAttempt() time.Time + func (t *Task) Ready() bool + func (t *Task) String() string + type TaskMatcher struct + func MatchTask(task *Task) *TaskMatcher + func (m *TaskMatcher) Matches(x interface{}) bool + func (m *TaskMatcher) String() string
Go to main page