operator

Documentation

Index

• func RunOperator(ctx context.Context, kubeconfig *restclient.Config) error
• type AWSTagController
  • func NewAWSTagController(infraConfigClient configv1client.InfrastructureInterface, ...) (*AWSTagController, error)
  • func (c *AWSTagController) Run(ctx context.Context)
• type AzurePathFixController
  • func NewAzurePathFixController(batchClient batchv1client.BatchV1Interface, ...) (*AzurePathFixController, error)
  • func (c *AzurePathFixController) Run(stopCh <-chan struct{})
• type AzureStackCloudController
  • func NewAzureStackCloudController(operatorClient v1helpers.OperatorClient, ...) (*AzureStackCloudController, error)
  • func (c *AzureStackCloudController) Run(ctx context.Context)
• type ClusterOperatorStatusController
  • func NewClusterOperatorStatusController(relatedObjects []configv1.ObjectReference, ...) (*ClusterOperatorStatusController, error)
  • func (c *ClusterOperatorStatusController) Run(stopCh <-chan struct{})
• type Controller
  • func NewController(eventRecorder events.Recorder, kubeconfig *restclient.Config, ...) (*Controller, error)
  • func (c *Controller) Bootstrap() error
  • func (c *Controller) RemoveResources(o *imageregistryv1.Config) error
  • func (c *Controller) Run(stopCh <-chan struct{})
• type ImageConfigController
  • func NewImageConfigController(configClient configset.ConfigV1Interface, ...) (*ImageConfigController, error)
  • func (icc *ImageConfigController) Run(stopCh <-chan struct{})
• type ImagePrunerController
  • func NewImagePrunerController(kubeClient kubeclient.Interface, ...) (*ImagePrunerController, error)
  • func (c *ImagePrunerController) Bootstrap() error
  • func (c *ImagePrunerController) Run(stopCh <-chan struct{})
• type ImageRegistryCertificatesController
  • func NewImageRegistryCertificatesController(kubeconfig *restclient.Config, coreClient corev1client.CoreV1Interface, ...) (*ImageRegistryCertificatesController, error)
  • func (c *ImageRegistryCertificatesController) Run(stopCh <-chan struct{})
• type MetricsController
  • func NewMetricsController(informer imageinformers.ImageStreamInformer) *MetricsController
  • func (m *MetricsController) Run(ctx context.Context)
• type NodeCADaemonController
  • func NewNodeCADaemonController(eventRecorder events.Recorder, appsClient appsv1client.AppsV1Interface, ...) (*NodeCADaemonController, error)
  • func (c *NodeCADaemonController) Run(stopCh <-chan struct{})

Functions

func RunOperator

func RunOperator(ctx context.Context, kubeconfig *restclient.Config) error

Types

type AWSTagController

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

AWSTagController is for storing internal data required for performing AWS controller operations

func NewAWSTagController

func NewAWSTagController(
	infraConfigClient configv1client.InfrastructureInterface,
	imageRegistryConfigClient imageregistryv1client.ConfigInterface,
	kubeInformerFactory kubeinformers.SharedInformerFactory,
	regopInformerFactory imageregistryinformers.SharedInformerFactory,
	routeInformerFactory routeinformers.SharedInformerFactory,
	configInformerFactory configinformers.SharedInformerFactory,
	openshiftConfigKubeInformerFactory kubeinformers.SharedInformerFactory,
	openshiftConfigManagedKubeInformerFactory kubeinformers.SharedInformerFactory,
	eventRecorder events.Recorder,
	featureGateAccessor featuregates.FeatureGateAccess,
) (*AWSTagController, error)

NewAWSTagController is for obtaining AWSTagController object required for invoking AWS Tag controller methods.

func (*AWSTagController) Run

func (c *AWSTagController) Run(ctx context.Context)

Run is the main method for starting the AWS controller

type AzurePathFixController

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

func NewAzurePathFixController

func NewAzurePathFixController(
	batchClient batchv1client.BatchV1Interface,
	operatorClient v1helpers.OperatorClient,
	jobInformer batchv1informers.JobInformer,
	imageRegistryConfigInformer imageregistryv1informers.ConfigInformer,
	infrastructureInformer configv1informers.InfrastructureInformer,
) (*AzurePathFixController, error)

func (*AzurePathFixController) Run

func (c *AzurePathFixController) Run(stopCh <-chan struct{})

type AzureStackCloudController

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

func NewAzureStackCloudController

func NewAzureStackCloudController(
	operatorClient v1helpers.OperatorClient,
	openshiftConfigInformer corev1informers.ConfigMapInformer,
) (*AzureStackCloudController, error)

func (*AzureStackCloudController) Run

func (c *AzureStackCloudController) Run(ctx context.Context)

type ClusterOperatorStatusController

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

func NewClusterOperatorStatusController

func NewClusterOperatorStatusController(
	relatedObjects []configv1.ObjectReference,
	configClient configv1client.ConfigV1Interface,
	clusterOperatorInformer configv1informers.ClusterOperatorInformer,
	imageRegistryConfigInformer imageregistryv1informers.ConfigInformer,
	imagePrunerInformer imageregistryv1informers.ImagePrunerInformer,
	deploymentInformer appsv1informers.DeploymentInformer,
) (*ClusterOperatorStatusController, error)

func (*ClusterOperatorStatusController) Run

func (c *ClusterOperatorStatusController) Run(stopCh <-chan struct{})

type Controller

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

Controller keeps track of openshift image registry components.

func NewController

func NewController(
	eventRecorder events.Recorder,
	kubeconfig *restclient.Config,
	kubeClient kubeclient.Interface,
	configClient configclient.Interface,
	imageregistryClient imageregistryclient.Interface,
	routeClient routeclient.Interface,
	kubeInformerFactory kubeinformers.SharedInformerFactory,
	openshiftConfigKubeInformerFactory kubeinformers.SharedInformerFactory,
	openshiftConfigManagedKubeInformerFactory kubeinformers.SharedInformerFactory,
	kubeSystemKubeInformerFactory kubeinformers.SharedInformerFactory,
	configInformerFactory configinformers.SharedInformerFactory,
	regopInformerFactory imageregistryinformers.SharedInformerFactory,
	routeInformerFactory routeinformers.SharedInformerFactory,
	featureGateAccessor featuregates.FeatureGateAccess,
) (*Controller, error)

NewController returns a controller for openshift image registry objects.

This controller keeps track of resources needed in order to have openshift internal registry working.

func (*Controller) Bootstrap

func (c *Controller) Bootstrap() error

Bootstrap registers this operator with OpenShift by creating an appropriate ClusterOperator custom resource. This function also creates the initial configuration for the Image Registry.

func (*Controller) RemoveResources

func (c *Controller) RemoveResources(o *imageregistryv1.Config) error

func (*Controller) Run

func (c *Controller) Run(stopCh <-chan struct{})

Run starts the Controller.

type ImageConfigController

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

ImageConfigController controls image.config.openshift.io/cluster.

Watches for changes on image registry routes and services, updating the resource status appropriately.

func NewImageConfigController

func NewImageConfigController(
	configClient configset.ConfigV1Interface,
	operatorClient v1helpers.OperatorClient,
	routeInformer routev1informers.RouteInformer,
	serviceInformer corev1informers.ServiceInformer,
	imageConfigInformer configv1informers.ImageInformer,
	clusterVersionInformer configv1informers.ClusterVersionInformer,
	imageStreamImportModeEnabled bool,
) (*ImageConfigController, error)

func (*ImageConfigController) Run

func (icc *ImageConfigController) Run(stopCh <-chan struct{})

type ImagePrunerController

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

ImagePrunerController keeps track of openshift image pruner components.

func NewImagePrunerController

func NewImagePrunerController(
	kubeClient kubeclient.Interface,
	imageregistryClient imageregistryclient.Interface,
	kubeInformerFactory kubeinformers.SharedInformerFactory,
	regopInformerFactory imageregistryinformers.SharedInformerFactory,
	imageConfigInformer configv1informers.ImageInformer,
) (*ImagePrunerController, error)

NewImagePrunerController returns a controller for openshift image pruner.

func (*ImagePrunerController) Bootstrap

func (c *ImagePrunerController) Bootstrap() error

Bootstrap creates the initial configuration for the Image Pruner.

func (*ImagePrunerController) Run

func (c *ImagePrunerController) Run(stopCh <-chan struct{})

Run starts the ImagePrunerController.

type ImageRegistryCertificatesController

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

func NewImageRegistryCertificatesController

func NewImageRegistryCertificatesController(
	kubeconfig *restclient.Config,
	coreClient corev1client.CoreV1Interface,
	operatorClient v1helpers.OperatorClient,
	configMapInformer corev1informers.ConfigMapInformer,
	secretInformer corev1informers.SecretInformer,
	serviceInformer corev1informers.ServiceInformer,
	imageConfigInformer configv1informers.ImageInformer,
	infrastructureInformer configv1informers.InfrastructureInformer,
	openshiftConfigInformer corev1informers.ConfigMapInformer,
	openshiftConfigManagedInformer corev1informers.ConfigMapInformer,
	imageRegistryConfigInformer imageregistryv1informers.ConfigInformer,
) (*ImageRegistryCertificatesController, error)

func (*ImageRegistryCertificatesController) Run

func (c *ImageRegistryCertificatesController) Run(stopCh <-chan struct{})

type MetricsController

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

MetricsController is a controller that runs from time to time and reports some metrics about the current status of the system.

func NewMetricsController

func NewMetricsController(informer imageinformers.ImageStreamInformer) *MetricsController

NewMetricsController returns a new MetricsController.

func (*MetricsController) Run

func (m *MetricsController) Run(ctx context.Context)

Run starts this controller. Runs the main loop in a separate go routine and bails out when the provided context is finished.

type NodeCADaemonController

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

func NewNodeCADaemonController

func NewNodeCADaemonController(
	eventRecorder events.Recorder,
	appsClient appsv1client.AppsV1Interface,
	operatorClient v1helpers.OperatorClient,
	daemonSetInformer appsv1informers.DaemonSetInformer,
	serviceInformer corev1informers.ServiceInformer,
) (*NodeCADaemonController, error)

func (*NodeCADaemonController) Run

func (c *NodeCADaemonController) Run(stopCh <-chan struct{})