controller

package

v0.1.10 Latest Latest Go to latest Published: Jun 1, 2023 License: Apache-2.0 Imports: 18 Imported by: 2

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/tliron/reposure

Links

Open Source Insights

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 ¶

View Source

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

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL