controllerutil

Documentation

Index

• Variables
• func GetConcurrencyOrDefaultCPUFactor(concurrency *configv1alpha1.Concurrency, defaultFactor int) int
• func GetConcurrencyOrDefaultNumber(concurrency *configv1alpha1.Concurrency, defaultNumber int) int
• func WaitForNamedCacheSyncWithTimeout(ctx context.Context, controllerName string, timeout time.Duration, ...) error

Variables

var (
	ErrWaitForCacheSyncTimeout = errors.New("timed out while waiting for cache to sync")
)

Functions

func GetConcurrencyOrDefaultCPUFactor

func GetConcurrencyOrDefaultCPUFactor(concurrency *configv1alpha1.Concurrency, defaultFactor int) int

GetConcurrencyOrDefaultCPUFactor returns the configured concurrency, or a default factor on the number of CPUs.

func GetConcurrencyOrDefaultNumber

func GetConcurrencyOrDefaultNumber(concurrency *configv1alpha1.Concurrency, defaultNumber int) int

GetConcurrencyOrDefaultNumber returns the configured concurrency, or a default number.

func WaitForNamedCacheSyncWithTimeout

func WaitForNamedCacheSyncWithTimeout(
	ctx context.Context, controllerName string, timeout time.Duration, cacheSyncs ...cache.InformerSynced,
) error

WaitForNamedCacheSyncWithTimeout is a wrapper around WaitForNamedCacheSync subject to a maximum timeout. Returns whether there was a successful or failed sync.