controllers

Documentation

Overview

Copyright 2020 Adobe All Rights Reserved.

NOTICE: Adobe permits you to use, modify, and distribute this file in accordance with the terms of the Adobe license agreement accompanying it. If you have received this file from a source other than Adobe, then your use, modification, or distribution of it requires the prior written permission of Adobe.

Index

• Constants
• func NewFixedItemIntervalRateLimiter(interval time.Duration) workqueue.RateLimiter
• type FixedItemIntervalRateLimiter
  • func (r *FixedItemIntervalRateLimiter) Forget(item interface{})
  • func (r *FixedItemIntervalRateLimiter) NumRequeues(item interface{}) int
  • func (r *FixedItemIntervalRateLimiter) When(item interface{}) time.Duration
• type KratosReconciler
  • func NewKratosReconciler(params *common.KratosParameters) (*KratosReconciler, error)
  • func (r *KratosReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)
  • func (r *KratosReconciler) SetupWithManager(mgr ctrl.Manager) error
• type Worker
  • func NewWorker(params *common.KratosParameters) (*Worker, error)

Constants

const (
	DELETED     bool = true
	NOT_DELETED bool = false
)

Functions

func NewFixedItemIntervalRateLimiter

func NewFixedItemIntervalRateLimiter(interval time.Duration) workqueue.RateLimiter

NewFixedItemIntervalRateLimiter creates a new instance of a RateLimiter using a fixed interval

Types

type FixedItemIntervalRateLimiter

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

func (*FixedItemIntervalRateLimiter) Forget

func (r *FixedItemIntervalRateLimiter) Forget(item interface{})

Forget indicates that an item is finished being retried.

func (*FixedItemIntervalRateLimiter) NumRequeues

func (r *FixedItemIntervalRateLimiter) NumRequeues(item interface{}) int

NumRequeues returns back how many failures the item has had

func (*FixedItemIntervalRateLimiter) When

func (r *FixedItemIntervalRateLimiter) When(item interface{}) time.Duration

When returns the interval of the rate limiter

type KratosReconciler

type KratosReconciler struct {
	client.Client
	// contains filtered or unexported fields
}

KratosReconciler reconciles a Kratos object

func NewKratosReconciler

func NewKratosReconciler(params *common.KratosParameters) (*KratosReconciler, error)

func (*KratosReconciler) Reconcile

func (r *KratosReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)

+kubebuilder:rbac:groups=scaling.core.adobe.com,resources=kratos,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=scaling.core.adobe.com,resources=kratos/status,verbs=get;update;patch

func (*KratosReconciler) SetupWithManager

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

type Worker

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

func NewWorker

func NewWorker(params *common.KratosParameters) (*Worker, error)