internal

Documentation

Index

• Constants
• func GetCacheOptions(isKymaManaged bool, istioNamespace, kcpNamespace, remoteNamespace string) cache.Options
• func GetResourceLabel(resource client.Object, labelName string) (string, error)
• func ManifestRateLimiter(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, remoteNamespace string) cache.Options

func GetResourceLabel

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

func ManifestRateLimiter

func ManifestRateLimiter(
	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)