poll

Documentation

Index

• type DefaultManager
  • func NewPollManager(providers provider.Providers, watcher Watcher) *DefaultManager
  • func (s *DefaultManager) Start(ctx context.Context) error
• type RepositoryWatcher
  • func NewRepositoryWatcher(providers provider.Providers, registryClient registry.Client) *RepositoryWatcher
  • func (w *RepositoryWatcher) Start(ctx context.Context)
  • func (w *RepositoryWatcher) Unwatch(imageName string) error
  • func (w *RepositoryWatcher) Watch(images ...*types.TrackedImage) error
• type WatchRepositoryTagsJob
  • func NewWatchRepositoryTagsJob(providers provider.Providers, registryClient registry.Client, ...) *WatchRepositoryTagsJob
  • func (j *WatchRepositoryTagsJob) Run()
• type WatchTagJob
  • func NewWatchTagJob(providers provider.Providers, registryClient registry.Client, ...) *WatchTagJob
  • func (j *WatchTagJob) Run()
• type Watcher

Types

type DefaultManager

type DefaultManager struct {
	// contains filtered or unexported fields
}

DefaultManager - default manager is responsible for scanning deployments and identifying deployments that have market

func NewPollManager

func NewPollManager(providers provider.Providers, watcher Watcher) *DefaultManager

NewPollManager - new default poller

func (*DefaultManager) Start

func (s *DefaultManager) Start(ctx context.Context) error

Start - start scanning deployment for changes

type RepositoryWatcher

type RepositoryWatcher struct {
	// contains filtered or unexported fields
}

RepositoryWatcher - repository watcher cron

func NewRepositoryWatcher

func NewRepositoryWatcher(providers provider.Providers, registryClient registry.Client) *RepositoryWatcher

NewRepositoryWatcher - create new repository watcher

func (*RepositoryWatcher) Start

func (w *RepositoryWatcher) Start(ctx context.Context)

Start - starts repository watcher

func (*RepositoryWatcher) Unwatch

func (w *RepositoryWatcher) Unwatch(imageName string) error

Unwatch - stop watching for changes

func (*RepositoryWatcher) Watch

func (w *RepositoryWatcher) Watch(images ...*types.TrackedImage) error

Watch - starts watching repository for changes, if it's already watching - ignores, if details changed - updates details

type WatchRepositoryTagsJob

type WatchRepositoryTagsJob struct {
	// contains filtered or unexported fields
}

WatchRepositoryTagsJob - watch all tags

func NewWatchRepositoryTagsJob

func NewWatchRepositoryTagsJob(providers provider.Providers, registryClient registry.Client, details *watchDetails) *WatchRepositoryTagsJob

NewWatchRepositoryTagsJob - new tags watcher job

func (*WatchRepositoryTagsJob) Run

func (j *WatchRepositoryTagsJob) Run()

Run - main function to check schedule

type WatchTagJob

type WatchTagJob struct {
	// contains filtered or unexported fields
}

WatchTagJob - Watch specific tag job

func NewWatchTagJob

func NewWatchTagJob(providers provider.Providers, registryClient registry.Client, details *watchDetails) *WatchTagJob

NewWatchTagJob - new watch tag job monitors specific tag by checking digest based on specified cron style schedule

func (*WatchTagJob) Run

func (j *WatchTagJob) Run()

Run - main function to check schedule

type Watcher

type Watcher interface {
	Watch(image ...*types.TrackedImage) error
	Unwatch(image string) error
}

Watcher - generic watcher interface