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, fs FileStore, backends *backend.Manager) *Executor + func (e *Executor) Exec(r persistedretry.Task) error + func (e *Executor) Name() string + type FileStore interface + DeleteCacheFileMetadata func(name string, md metadata.Metadata) error + GetCacheFileReader func(name string) (store.FileReader, error) + type NameQuery struct + func NewNameQuery(name string) *NameQuery + type Store struct + func NewStore(db *sqlx.DB) *Store + 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 + Digest core.Digest + Failures int + LastAttempt time.Time + Name string + Namespace string + func NewTask(namespace, name string, delay time.Duration) *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