poll

package
v0.0.0-...-c5ab296 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 23, 2019 License: MPL-2.0 Imports: 16 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

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