controllers

Documentation

Index

• Constants
• func NewRateLimiter(c RateLimiterConfig) ratelimiter.RateLimiter
• func UpdateApiGatewayStatus(ctx context.Context, k8sClient client.Client, ...) error
• type RateLimiterConfig
• type State
• type Status
  • func DeletingStatus(condition *metav1.Condition) Status
  • func ErrorStatus(err error, description string, condition *metav1.Condition) Status
  • func ProcessingStatus(condition *metav1.Condition) Status
  • func ReadyStatus(condition *metav1.Condition) Status
  • func WarningStatus(err error, description string, condition *metav1.Condition) Status

Constants

const (
	RateLimiterBurst            = 200
	RateLimiterFrequency        = 30
	RateLimiterFailureBaseDelay = 1 * time.Second
	RateLimiterFailureMaxDelay  = 1000 * time.Second
)

Functions

func NewRateLimiter

func NewRateLimiter(c RateLimiterConfig) ratelimiter.RateLimiter

NewRateLimiter returns a rate limiter for a client-go.workqueue. It has both an overall (token bucket) and per-item (exponential) rate limiting.

func UpdateApiGatewayStatus

func UpdateApiGatewayStatus(ctx context.Context, k8sClient client.Client, apiGatewayCR *operatorv1alpha1.APIGateway, status Status) error

Types

type RateLimiterConfig

type RateLimiterConfig struct {
	Burst            int
	Frequency        int
	FailureBaseDelay time.Duration
	FailureMaxDelay  time.Duration
}

type State

type State int

const (
	Ready      State = 0
	Error      State = 1
	Warning    State = 2
	Deleting   State = 3
	Processing State = 4
)

type Status

type Status interface {
	NestedError() error
	ToAPIGatewayStatus() (operatorv1alpha1.APIGatewayStatus, error)
	ToAPIRuleStatus() (processing.ReconciliationStatus, error)
	IsReady() bool
	IsWarning() bool
	IsError() bool
	State() State
	Description() string
	Condition() *metav1.Condition
}

func DeletingStatus

func DeletingStatus(condition *metav1.Condition) Status

func ErrorStatus

func ErrorStatus(err error, description string, condition *metav1.Condition) Status

func ProcessingStatus

func ProcessingStatus(condition *metav1.Condition) Status

func ReadyStatus

func ReadyStatus(condition *metav1.Condition) Status

func WarningStatus

func WarningStatus(err error, description string, condition *metav1.Condition) Status