controller

Documentation

Index

• Constants
• type Controller
  • func NewController(context contextpkg.Context, toolName string, clusterMode bool, ...) *Controller
  • func (self *Controller) Run(concurrency uint, startup func()) error
  • func (self *Controller) UpdateRegistrySurrogatePod(registry *resources.Registry, surrogatePod string) (*resources.Registry, error)

Constants

const (
	NamePrefix              = "reposure"
	PartOf                  = "Reposure"
	ManagedBy               = "Reposure"
	OperatorImageReference  = "tliron/reposure-operator"
	SurrogateImageReference = "tliron/reposure-surrogate"
	SimpleImageReference    = "library/registry"
)

Types

type Controller

type Controller struct {
	Config      *restpkg.Config
	Dynamic     *kubernetesutil.Dynamic
	Kubernetes  kubernetes.Interface
	Reposure    reposureclientset.Interface
	Client      *adminclient.Client
	CachePath   string
	StopChannel <-chan struct{}

	Processors *kubernetesutil.Processors
	Events     record.EventRecorder

	KubernetesInformerFactory informers.SharedInformerFactory
	ReposureInformerFactory   reposureinformers.SharedInformerFactory

	Registries reposurelisters.RegistryLister

	Context contextpkg.Context
	Log     commonlog.Logger
}

func NewController

func NewController(context contextpkg.Context, toolName string, clusterMode bool, clusterRole string, namespace string, dynamic dynamicpkg.Interface, kubernetes kubernetes.Interface, apiExtensions apiextensionspkg.Interface, reposure reposureclientset.Interface, config *restpkg.Config, informerResyncPeriod time.Duration, stopChannel <-chan struct{}) *Controller

func (*Controller) Run

func (self *Controller) Run(concurrency uint, startup func()) error

func (*Controller) UpdateRegistrySurrogatePod

func (self *Controller) UpdateRegistrySurrogatePod(registry *resources.Registry, surrogatePod string) (*resources.Registry, error)