controllersdi

Documentation

Index

• type AssociatedObjects
• type ClusterBomCleaner
• type ClusterBomReconciler
  • func NewClusterBomReconciler(cli client.Client, log logr.Logger, scheme *runtime.Scheme, auditLog bool, ...) (*ClusterBomReconciler, error)
  • func (r *ClusterBomReconciler) Close() error
  • func (r *ClusterBomReconciler) GetLastAVCheckReconcileTime() time.Time
  • func (r *ClusterBomReconciler) GetName() string
  • func (r *ClusterBomReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ClusterBomReconciler) SetupWithManager(mgr ctrl.Manager) error
• type ClusterBomStateReconciler
  • func (r *ClusterBomStateReconciler) GetLastAVCheckReconcileTime() time.Time
  • func (r *ClusterBomStateReconciler) GetName() string
  • func (r *ClusterBomStateReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ClusterBomStateReconciler) SetupWithManager(mgr ctrl.Manager) error
• type DeployerFactory
  • func NewDeploymentFactory(crAndSecretClient client.Client, uncachedClient synchronize.UncachedClient, ...) DeployerFactory
• type DeploymentReconciler
  • func NewDeploymentReconciler(deployerFactory DeployerFactory, crAndSecretClient client.Client, ...) *DeploymentReconciler
  • func (r *DeploymentReconciler) GetLastAVCheckReconcileTime() time.Time
  • func (r *DeploymentReconciler) GetName() string
  • func (r *DeploymentReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *DeploymentReconciler) SetupWithManager(mgr ctrl.Manager) error
• type RealReconcileClock
  • func (r *RealReconcileClock) Now() time.Time
  • func (r *RealReconcileClock) Sleep(d time.Duration)
• type ReconcileClock
• type ReconcileController
  • func (r *ReconcileController) Reconcile(reconcileInterval, restartKappInterval time.Duration)

Types

type AssociatedObjects

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

type ClusterBomCleaner

type ClusterBomCleaner struct {
	LastCheck int64
	Succeeded bool
}

ClusterBomCleaner contains the information whether a clusterbom cleanup was done, and if it has failed when the cleanup was last tried. The clusterbom cleanup is performed once. It updates the status of empty clusterboms.

type ClusterBomReconciler

type ClusterBomReconciler struct {
	client.Client
	Log    logr.Logger
	Scheme *runtime.Scheme

	AVCheck       *avcheck.AVCheck
	AVCheckConfig *avcheck.Configuration
	// contains filtered or unexported fields
}

ClusterBomReconciler reconciles a ClusterBom object

func NewClusterBomReconciler

func NewClusterBomReconciler(cli client.Client, log logr.Logger, scheme *runtime.Scheme, auditLog bool,
	blockObject *synchronize.BlockObject, av *avcheck.AVCheck, uncachedClient, hubControllerClient synchronize.UncachedClient,
	avCheckConfig *avcheck.Configuration) (*ClusterBomReconciler, error)

func (*ClusterBomReconciler) Close

func (r *ClusterBomReconciler) Close() error

func (*ClusterBomReconciler) GetLastAVCheckReconcileTime

func (r *ClusterBomReconciler) GetLastAVCheckReconcileTime() time.Time

func (*ClusterBomReconciler) GetName

func (r *ClusterBomReconciler) GetName() string

func (*ClusterBomReconciler) Reconcile

func (r *ClusterBomReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*ClusterBomReconciler) SetupWithManager

func (r *ClusterBomReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager is used to create a new instance of the ClusterBomController.

type ClusterBomStateReconciler

type ClusterBomStateReconciler struct {
	client.Client
	Log            logr.Logger
	Scheme         *runtime.Scheme
	Cleaner        ClusterBomCleaner
	BlockObject    *synchronize.BlockObject
	AVCheck        *avcheck.AVCheck
	AvCheckConfig  *avcheck.Configuration
	UncachedClient synchronize.UncachedClient
}

ClusterBomStateReconciler reconciles a DeployItem object

func (*ClusterBomStateReconciler) GetLastAVCheckReconcileTime

func (r *ClusterBomStateReconciler) GetLastAVCheckReconcileTime() time.Time

func (*ClusterBomStateReconciler) GetName

func (r *ClusterBomStateReconciler) GetName() string

func (*ClusterBomStateReconciler) Reconcile

func (r *ClusterBomStateReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*ClusterBomStateReconciler) SetupWithManager

func (r *ClusterBomStateReconciler) SetupWithManager(mgr ctrl.Manager) error

type DeployerFactory

type DeployerFactory interface {
	GetDeployer(configType string) (deployutil.DeployItemDeployer, error)
}

func NewDeploymentFactory

func NewDeploymentFactory(crAndSecretClient client.Client, uncachedClient synchronize.UncachedClient,
	appRepoClient client.Client, blockObject *synchronize.BlockObject,
	reconcileIntervalMinutes int64) DeployerFactory

type DeploymentReconciler

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

DeploymentReconciler reconciles a DeployItem

func NewDeploymentReconciler

func NewDeploymentReconciler(deployerFactory DeployerFactory, crAndSecretClient client.Client, log logr.Logger,
	scheme *runtime.Scheme, threadCounterLog *util.ThreadCounterMap, blockObject *synchronize.BlockObject,
	avCheck *avcheck.AVCheck, uncachedClient synchronize.UncachedClient, eventRecorder record.EventRecorder) *DeploymentReconciler

func (*DeploymentReconciler) GetLastAVCheckReconcileTime

func (r *DeploymentReconciler) GetLastAVCheckReconcileTime() time.Time

func (*DeploymentReconciler) GetName

func (r *DeploymentReconciler) GetName() string

func (*DeploymentReconciler) Reconcile

func (r *DeploymentReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*DeploymentReconciler) SetupWithManager

func (r *DeploymentReconciler) SetupWithManager(mgr ctrl.Manager) error

type RealReconcileClock

type RealReconcileClock struct{}

func (*RealReconcileClock) Now

func (r *RealReconcileClock) Now() time.Time

func (*RealReconcileClock) Sleep

func (r *RealReconcileClock) Sleep(d time.Duration)

type ReconcileClock

type ReconcileClock interface {
	Now() time.Time
	Sleep(duration time.Duration)
}

type ReconcileController

type ReconcileController struct {
	Client              client.Client
	UncachedClient      synchronize.UncachedClient
	HubControllerClient synchronize.UncachedClient
	Log                 logr.Logger
	Scheme              *runtime.Scheme
	Clock               ReconcileClock
	ConfigMapKey        types.NamespacedName
	UniqueID            string
	SyncDisabled        bool
}

func (*ReconcileController) Reconcile

func (r *ReconcileController) Reconcile(reconcileInterval, restartKappInterval time.Duration)