controller

Documentation

Index

• Constants
• func NewDynamicRequiredManifestController(name string, manifest []byte, key types.NamespacedName, ...) factory.Controller
• func NewIncompatibleOperatorController(name string, nextOCPMinorVersion *semver.Version, ...) factory.Controller
• func NewProxyController(name string, proxyClient *clients.ProxyClient, ...) factory.Controller
• func NewStaticUpgradeableConditionController(name string, operatorClient *clients.OperatorClient, ...) factory.Controller
• func UpdateDeploymentProxyHook(pc clients.ProxyClientInterface) deploymentcontroller.DeploymentHookFunc
• func UpdateProxyEnvironment(logger logr.Logger, pc clients.ProxyClientInterface) error
• type Builder
  • func (b *Builder) BuildControllers(subDirectories ...string) (map[string]factory.Controller, map[string]factory.Controller, ...)
• type ResourceClient

Constants

const (
	HTTPProxy  = "HTTP_PROXY"
	HTTPSProxy = "HTTPS_PROXY"
	NoProxy    = "NO_PROXY"
)

Functions

func NewDynamicRequiredManifestController

func NewDynamicRequiredManifestController(name string, manifest []byte, key types.NamespacedName, gvr schema.GroupVersionResource, operatorClient *clients.OperatorClient, dynamicClient dynamic.Interface, resourceClient ResourceClient, recorder events.Recorder) factory.Controller

func NewIncompatibleOperatorController

func NewIncompatibleOperatorController(name string, nextOCPMinorVersion *semver.Version, kubeclient kubernetes.Interface, clusterExtensionClient *clients.ClusterExtensionClient, operatorClient *clients.OperatorClient, eventRecorder events.Recorder) factory.Controller

func NewProxyController

func NewProxyController(name string, proxyClient *clients.ProxyClient, operatorClient *clients.OperatorClient, eventRecorder events.Recorder) factory.Controller

func NewStaticUpgradeableConditionController

func NewStaticUpgradeableConditionController(name string, operatorClient *clients.OperatorClient, eventRecorder events.Recorder, prefixes []string) factory.Controller

func UpdateDeploymentProxyHook

func UpdateDeploymentProxyHook(pc clients.ProxyClientInterface) deploymentcontroller.DeploymentHookFunc

func UpdateProxyEnvironment

func UpdateProxyEnvironment(logger logr.Logger, pc clients.ProxyClientInterface) error

Types

type Builder

type Builder struct {
	Assets            fs.FS
	Clients           *clients.Clients
	ControllerContext *controllercmd.ControllerContext
	KnownRESTMappings map[schema.GroupVersionKind]*meta.RESTMapping
}

func (*Builder) BuildControllers

func (b *Builder) BuildControllers(subDirectories ...string) (map[string]factory.Controller, map[string]factory.Controller, map[string]factory.Controller, []configv1.ObjectReference, error)

type ResourceClient

type ResourceClient interface {
	Get(types.NamespacedName) (runtime.Object, error)
	Informer() cache.SharedIndexInformer
}