tagreplication

package

Go to main page

Versions in this module

v0

v0.1.4

May 6, 2020 GO-2023-1505

GO-2023-1505: Arbitrary file read vulnerability in github.com/uber/kraken

v0.1.3

Aug 26, 2019 GO-2023-1505

GO-2023-1505: Arbitrary file read vulnerability in github.com/uber/kraken

v0.1.2

Apr 9, 2019 GO-2023-1505

GO-2023-1505: Arbitrary file read vulnerability in github.com/uber/kraken

Changes in this version

type Task

+ func (t *Task) Tags() map[string]string

v0.1.1

Mar 11, 2019 GO-2023-1505

GO-2023-1505: Arbitrary file read vulnerability in github.com/uber/kraken

v0.1.0

Feb 23, 2019 GO-2023-1505

GO-2023-1505: Arbitrary file read vulnerability in github.com/uber/kraken

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL