controller

Documentation

Index

• Constants
• type ConfigMapControllerConfigProvider
  • func NewControllerConfigProvider(stopCh chan struct{}, clientset kubernetes.Interface, ...) ConfigMapControllerConfigProvider
  • func (cp *ConfigMapControllerConfigProvider) GetConfig() (ControllerConfig, error)
• type ControllerConfig
  • func NewControllerConfigFrom(config config.Config) ControllerConfig
  • func (c ControllerConfig) ImportWithoutTemplateEnabled() bool
  • func (c ControllerConfig) OsConfigMapName() string
  • func (c ControllerConfig) OsConfigMapNamespace() string
  • func (c ControllerConfig) WarmImportConsecutiveFailures() int
  • func (c ControllerConfig) WarmImportIntervalMinutes() int
  • func (c ControllerConfig) WarmImportMaxFailures() int
• type ControllerConfigProvider

Constants

const (
	// OsConfigMapNamespaceKey defines the configuration key for the OS mapping config map namespace
	OsConfigMapNamespaceKey = "osConfigMap.namespace"

	// OsConfigMapNameKey defines the configuration key for the OS mapping config map name
	OsConfigMapNameKey = "osConfigMap.name"

	// WarmImportMaxFailuresKey defines the total number of failures to tolerate before failing the warm import
	WarmImportMaxFailuresKey = "warmImport.maxFailures"

	// WarmImportConsecutiveFailuresKey defines the number of consecutive failures to tolerate before failing the warm import
	WarmImportConsecutiveFailuresKey = "warmImport.consecutiveFailures"

	// WarmImportIntervalMinutesKey defines how long to wait between warm import iterations
	WarmImportIntervalMinutesKey = "warmImport.intervalMinutes"

	// ImportWithoutTemplateKey defines whether imports are permitted to run if an Openshift VM template can't be found.
	ImportWithoutTemplateKey = "importWithoutTemplate"
)

const (
	// ConfigMapName defines the name of the controller config map
	ConfigMapName = "vm-import-controller-config"
)

Types

type ConfigMapControllerConfigProvider

type ConfigMapControllerConfigProvider struct {
	config.Provider
}

ConfigMapControllerConfigProvider is responsible for providing the current controller config

func NewControllerConfigProvider

func NewControllerConfigProvider(stopCh chan struct{}, clientset kubernetes.Interface, controllerNamespace string) ConfigMapControllerConfigProvider

NewControllerConfigProvider creates new controller config provider that will ensure that the provided config is up to date

func (*ConfigMapControllerConfigProvider) GetConfig

func (cp *ConfigMapControllerConfigProvider) GetConfig() (ControllerConfig, error)

GetConfig provides the most current controller config

type ControllerConfig

type ControllerConfig struct {
	config.Config
}

ControllerConfig stores controller runtime configuration

func NewControllerConfigFrom

func NewControllerConfigFrom(config config.Config) ControllerConfig

NewControllerConfigFrom creates new controller config from given Config

func (ControllerConfig) ImportWithoutTemplateEnabled

func (c ControllerConfig) ImportWithoutTemplateEnabled() bool

func (ControllerConfig) OsConfigMapName

func (c ControllerConfig) OsConfigMapName() string

OsConfigMapName provides name of the the OS mapping ConfigMap. Empty string is returned when the name is not present.

func (ControllerConfig) OsConfigMapNamespace

func (c ControllerConfig) OsConfigMapNamespace() string

OsConfigMapNamespace provides namespace where the OS mapping ConfigMap resides. Empty string is returned when the namespace is not present.

func (ControllerConfig) WarmImportConsecutiveFailures

func (c ControllerConfig) WarmImportConsecutiveFailures() int

func (ControllerConfig) WarmImportIntervalMinutes

func (c ControllerConfig) WarmImportIntervalMinutes() int

func (ControllerConfig) WarmImportMaxFailures

func (c ControllerConfig) WarmImportMaxFailures() int

type ControllerConfigProvider

type ControllerConfigProvider interface {
	GetConfig() (ControllerConfig, error)
}

ControllerConfigProvider defines controller config access operations