controllers

Documentation

Index

• type CTX_VALUE_KEY
• type Cron
  • func NewCron() *Cron
  • func (c *Cron) Add(namespacedName types.NamespacedName, cronItems []CronItem) error
  • func (c *Cron) Clear(namespacedName types.NamespacedName)
  • func (c *Cron) Start()
  • func (c *Cron) Stop()
• type CronContext
  • func NewCronContext(reconciler *LendingConfigReconciler, lendingConfig *LendingConfig, ...) *CronContext
  • func (cronctx *CronContext) Run()
• type CronItem
• type GlobalCronContext
• type LendingConfig
  • func (config *LendingConfig) ActivateTargetResources(ctx context.Context, reconciler *LendingConfigReconciler) error
  • func (config *LendingConfig) ClearSchedules(ctx context.Context, reconciler *LendingConfigReconciler) error
  • func (config *LendingConfig) DeactivateTargetResources(ctx context.Context, reconciler *LendingConfigReconciler) ([]v1alpha1.LendingReference, error)
  • func (config *LendingConfig) ToCompatible() *clusterlendingmanagerv1alpha1.LendingConfig
  • func (config *LendingConfig) ToNamespacedName() types.NamespacedName
  • func (config *LendingConfig) UpdateSchedules(ctx context.Context, reconciler *LendingConfigReconciler) error
• type LendingConfigEvent
• type LendingConfigReconciler
  • func (r *LendingConfigReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *LendingConfigReconciler) SetupWithManager(mgr ctrl.Manager) error
• type LendingEvent

Types

type CTX_VALUE_KEY

type CTX_VALUE_KEY string

var (
	CTX_VALUE_NAME      CTX_VALUE_KEY = "name"
	CTX_VALUE_NAMESPACE CTX_VALUE_KEY = "namespace"
)

type Cron

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

func NewCron

func NewCron() *Cron

func (*Cron) Add

func (c *Cron) Add(namespacedName types.NamespacedName, cronItems []CronItem) error

func (*Cron) Clear

func (c *Cron) Clear(namespacedName types.NamespacedName)

func (*Cron) Start

func (c *Cron) Start()

func (*Cron) Stop

func (c *Cron) Stop()

type CronContext

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

func NewCronContext

func NewCronContext(
	reconciler *LendingConfigReconciler,
	lendingConfig *LendingConfig,
	event LendingEvent,
) *CronContext

func (*CronContext) Run

func (cronctx *CronContext) Run()

type CronItem

type CronItem struct {
	Cron string
	Job  cron.Job
}

type GlobalCronContext

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

type LendingConfig

type LendingConfig clusterlendingmanagerv1alpha1.LendingConfig

func (*LendingConfig) ActivateTargetResources

func (config *LendingConfig) ActivateTargetResources(ctx context.Context, reconciler *LendingConfigReconciler) error

func (*LendingConfig) ClearSchedules

func (config *LendingConfig) ClearSchedules(ctx context.Context, reconciler *LendingConfigReconciler) error

func (*LendingConfig) DeactivateTargetResources

func (config *LendingConfig) DeactivateTargetResources(ctx context.Context, reconciler *LendingConfigReconciler) ([]v1alpha1.LendingReference, error)

func (*LendingConfig) ToCompatible

func (config *LendingConfig) ToCompatible() *clusterlendingmanagerv1alpha1.LendingConfig

func (*LendingConfig) ToNamespacedName

func (config *LendingConfig) ToNamespacedName() types.NamespacedName

func (*LendingConfig) UpdateSchedules

func (config *LendingConfig) UpdateSchedules(ctx context.Context, reconciler *LendingConfigReconciler) error

type LendingConfigEvent

type LendingConfigEvent = string

const (
	SchedulesUpdated LendingConfigEvent = "SchedulesUpdated"
	SchedulesCleared LendingConfigEvent = "SchedulesCleared"
	LendingStarted   LendingConfigEvent = "LendingStarted"
	LendingEnded     LendingConfigEvent = "endingEnded"
)

type LendingConfigReconciler

type LendingConfigReconciler struct {
	client.Client
	Recorder record.EventRecorder
	Cron     *Cron
}

LendingConfigReconciler reconciles a LendingConfig object

func (*LendingConfigReconciler) Reconcile

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

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the LendingConfig object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.11.0/pkg/reconcile

func (*LendingConfigReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type LendingEvent

type LendingEvent string

const (
	LendingStart LendingEvent = "LendingStart"
	LendingEnd   LendingEvent = "LendingEnd"
)