internal

Documentation

Index

• Constants
• func GetCacheOptions(isKymaManaged bool, istioNamespace, kcpNamespace string) cache.Options
• func GetResourceLabel(resource client.Object, labelName string) (string, error)
• func RateLimiter(failureBaseDelay time.Duration, failureMaxDelay time.Duration, frequency int, ...) workqueue.TypedRateLimiter[ctrl.Request]
• type CacheOptions
• type DefaultCacheOptions
  • func (c *DefaultCacheOptions) GetCacheOptions() cache.Options
• type KcpCacheOptions
  • func (c *KcpCacheOptions) GetCacheOptions() cache.Options
• type ManifestResources
  • func ParseManifestToObjects(path string) (ManifestResources, error)

Constants

const (
	DebugLogLevel = 2
	TraceLogLevel = 3
)

Functions

func GetCacheOptions

func GetCacheOptions(isKymaManaged bool, istioNamespace, kcpNamespace string) cache.Options

func GetResourceLabel

func GetResourceLabel(resource client.Object, labelName string) (string, error)

func RateLimiter

func RateLimiter(
	failureBaseDelay time.Duration, failureMaxDelay time.Duration,
	frequency int, burst int,
) workqueue.TypedRateLimiter[ctrl.Request]

Types

type CacheOptions

type CacheOptions interface {
	GetCacheOptions() cache.Options
}

type DefaultCacheOptions

type DefaultCacheOptions struct {
	CacheOptions cache.Options
}

func (*DefaultCacheOptions) GetCacheOptions

func (c *DefaultCacheOptions) GetCacheOptions() cache.Options

type KcpCacheOptions

type KcpCacheOptions struct {
	CacheOptions cache.Options
	// contains filtered or unexported fields
}

func (*KcpCacheOptions) GetCacheOptions

func (c *KcpCacheOptions) GetCacheOptions() cache.Options

type ManifestResources

type ManifestResources struct {
	Items []*unstructured.Unstructured
}

ManifestResources holds a collection of objects, so that we can filter / sequence them.

func ParseManifestToObjects

func ParseManifestToObjects(path string) (ManifestResources, error)