controllers

package

v0.0.0-...-fe2f487 Latest Latest Go to latest Published: Apr 25, 2025 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/kyma-project/api-gateway

Documentation ¶

Index ¶

Constants
func NewRateLimiter(c RateLimiterConfig) workqueue.TypedRateLimiter[ctrl.Request]
func UpdateApiGatewayStatus(ctx context.Context, k8sClient client.Client, ...) error
type RateLimiterConfig
type State
type Status

Constants ¶

View Source

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

Variables ¶

This section is empty.

Functions ¶

func NewRateLimiter ¶

func NewRateLimiter(c RateLimiterConfig) workqueue.TypedRateLimiter[ctrl.Request]

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)
	V1beta1Status() (processingStatus.ReconciliationV1beta1Status, error)
	V2alpha1Status() (processingStatus.ReconciliationV2alpha1Status, 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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
certificate
gateway
ratelimit
operator

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL