controller

Documentation

Index

• Variables
• type ImportController
  • func (c *ImportController) Next(stream *api.ImageStream, notifier Notifier) error
  • func (c *ImportController) NextTimed(stream *api.ImageStream) error
  • func (c *ImportController) NextTimedByName(namespace, name string) error
• type ImportControllerFactory
  • func (f *ImportControllerFactory) Create() (controller.RunnableController, controller.StoppableController)
• type Notifier
• type NotifierFunc
  • func (fn NotifierFunc) Importing(stream *api.ImageStream)

Variables

var ErrNotImportable = errors.New("the specified stream cannot be imported")

Types

type ImportController

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

func (*ImportController) Next

func (c *ImportController) Next(stream *api.ImageStream, notifier Notifier) error

Next processes the given image stream, looking for streams that have DockerImageRepository set but have not yet been marked as "ready". If transient errors occur, err is returned but the image stream is not modified (so it will be tried again later). If a permanent failure occurs the image is marked with an annotation and conditions are set on the status tags. The tags of the original spec image are left as is (those are updated through status).

There are 3 scenarios:

1. spec.DockerImageRepository defined without any tags results in all tags being imported from upstream image repository

2. spec.DockerImageRepository + tags defined - import all tags from upstream image repository, and all the specified which (if name matches) will overwrite the default ones. Additionally: for kind == DockerImage import or reference underlying image, exact tag (not provided means latest), for kind != DockerImage reference tag from the same or other ImageStream

3. spec.DockerImageRepository not defined - import tags per each definition.

Notifier, if passed, will be invoked if the stream is going to be imported.

func (*ImportController) NextTimed

func (c *ImportController) NextTimed(stream *api.ImageStream) error

func (*ImportController) NextTimedByName

func (c *ImportController) NextTimedByName(namespace, name string) error

type ImportControllerFactory

type ImportControllerFactory struct {
	Client               client.Interface
	ResyncInterval       time.Duration
	MinimumCheckInterval time.Duration
	ImportRateLimiter    flowcontrol.RateLimiter
	ScheduleEnabled      bool
}

ImportControllerFactory can create an ImportController.

func (*ImportControllerFactory) Create

func (f *ImportControllerFactory) Create() (controller.RunnableController, controller.StoppableController)

Create creates an ImportController.

type Notifier

type Notifier interface {
	// Importing is invoked when the controller is going to import an image stream
	Importing(stream *api.ImageStream)
}

Notifier provides information about when the controller makes a decision

type NotifierFunc

type NotifierFunc func(stream *api.ImageStream)

NotifierFunc implements Notifier

func (NotifierFunc) Importing

func (fn NotifierFunc) Importing(stream *api.ImageStream)

Importing adapts NotifierFunc to Notifier