controllers

Documentation

Index

• type RpaasInstanceReconciler
  • func (r *RpaasInstanceReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *RpaasInstanceReconciler) SetupWithManager(mgr ctrl.Manager) error
• type RpaasValidationReconciler
  • func (r *RpaasValidationReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *RpaasValidationReconciler) SetupWithManager(mgr ctrl.Manager) error
• type SystemRolloutRateLimiter
  • func NewSystemRolloutRateLimiter(operations int, interval time.Duration) SystemRolloutRateLimiter
• type SystemRolloutReservation
  • func NoopReservation() SystemRolloutReservation

Types

type RpaasInstanceReconciler

type RpaasInstanceReconciler struct {
	client.Client
	Log               logr.Logger
	SystemRateLimiter SystemRolloutRateLimiter
	EventRecorder     record.EventRecorder
}

RpaasInstanceReconciler reconciles a RpaasInstance object

func (*RpaasInstanceReconciler) Reconcile

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

func (*RpaasInstanceReconciler) SetupWithManager

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

type RpaasValidationReconciler

type RpaasValidationReconciler struct {
	client.Client
	Log logr.Logger
}

RpaasValidationReconciler reconciles a RpaasValidation object

func (*RpaasValidationReconciler) Reconcile

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

func (*RpaasValidationReconciler) SetupWithManager

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

type SystemRolloutRateLimiter

type SystemRolloutRateLimiter interface {
	Reserve() (allowed bool, reservation SystemRolloutReservation)
}

func NewSystemRolloutRateLimiter

func NewSystemRolloutRateLimiter(operations int, interval time.Duration) SystemRolloutRateLimiter

type SystemRolloutReservation

type SystemRolloutReservation interface {
	Cancel()
}

func NoopReservation

func NoopReservation() SystemRolloutReservation