controller

Documentation

Index

• type ConfigurationController
  • func (cc *ConfigurationController) CollectInitially(collector config.ConfigurationCollector) error
  • func (cc *ConfigurationController) Initialize(kubeConfig *rest.Config, collector config.ConfigurationCollector, ...) error
  • func (cc *ConfigurationController) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (cc *ConfigurationController) SetupWithManager(mgr ctrl.Manager) error
• type GenericController
  • func (gc *GenericController) InjectDependencies(recorder record.EventRecorder, kubeConfig *rest.Config, ...) error
  • func (gc *GenericController) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (gc *GenericController) SetupWithManager(mgr ctrl.Manager) error

Types

type ConfigurationController

type ConfigurationController struct {
	Provider config.ConfigurationProviderInterface
	// contains filtered or unexported fields
}

ConfigurationController is reconciling CRD that provides configuration

func (*ConfigurationController) CollectInitially

func (cc *ConfigurationController) CollectInitially(collector config.ConfigurationCollector) error

func (*ConfigurationController) Initialize

func (cc *ConfigurationController) Initialize(kubeConfig *rest.Config, collector config.ConfigurationCollector,
	logger *logging.InternalLogger, kvStore store.Operator, schema *config.SchemaValidator) error

func (*ConfigurationController) Reconcile

func (cc *ConfigurationController) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*ConfigurationController) SetupWithManager

func (cc *ConfigurationController) SetupWithManager(mgr ctrl.Manager) error

type GenericController

type GenericController struct {
	ObjectType client.Object

	// e.g. Kubernetes batch/v1 Job, Argo Workflow or Tekton Pipeline
	PipelineInfoProvider provider.Provider

	// e.g. a Gitlab, Gitea, Bitbucket, MS Teams, etc.
	FeedbackReceiver feedback.Receiver

	// simple key-value store
	Store store.Operator

	// error handling
	DelayAfterErrorNum          int
	RequeueDelaySecs            int
	StopProcessingAfterErrorNum int
	// contains filtered or unexported fields
}

func (*GenericController) InjectDependencies

func (gc *GenericController) InjectDependencies(recorder record.EventRecorder, kubeConfig *rest.Config,
	logger *logging.InternalLogger, configProvider config.ConfigurationProviderInterface, cfgSchema config.Validator) error

InjectDependencies is wiring dependencies to all services

func (*GenericController) Reconcile

func (gc *GenericController) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*GenericController) SetupWithManager

func (gc *GenericController) SetupWithManager(mgr ctrl.Manager) error