common

Documentation

Index

• Constants
• func GetOwnerCheckResultAndContext(ctx context.Context, c client.Client, namespace, shootName, key string) (bool, context.Context, func(), error)
• type ChartRendererContext
  • func NewChartRendererContext(factory chartrenderer.Factory) ChartRendererContext
  • func (cc *ChartRendererContext) ChartRenderer() chartrenderer.Interface
  • func (cc *ChartRendererContext) InjectConfig(config *rest.Config) error
• type Checker
  • func NewOwnerChecker(ownerName, ownerID string, resolver Resolver, logger logr.Logger) Checker
• type CheckerFactory
  • func NewOwnerCheckerFactory(resolver Resolver, logger logr.Logger) CheckerFactory
• type ClientContext
  • func NewClientContext(client client.Client, scheme *runtime.Scheme, decoder runtime.Decoder) ClientContext
  • func (cc *ClientContext) Client() client.Client
  • func (cc *ClientContext) Decoder() runtime.Decoder
  • func (cc *ClientContext) InjectClient(client client.Client) error
  • func (cc *ClientContext) InjectScheme(scheme *runtime.Scheme) error
  • func (cc *ClientContext) Scheme() *runtime.Scheme
• type RESTConfigContext
  • func (cc *RESTConfigContext) InjectConfig(config *rest.Config) error
  • func (cc *RESTConfigContext) RESTConfig() *rest.Config
• type Resolver
• type Watchdog
  • func NewCheckerWatchdog(checker Checker, interval, timeout time.Duration, clock clock.Clock, ...) Watchdog
• type WatchdogFactory
  • func NewCheckerWatchdogFactory(checkerFactory CheckerFactory, interval, timeout time.Duration, ...) WatchdogFactory
• type WatchdogManager
  • func GetDefaultOwnerCheckWatchdogManager() WatchdogManager
  • func NewWatchdogManager(watchdogFactory WatchdogFactory, ttl time.Duration, clk clock.Clock, ...) WatchdogManager

Constants

const (
	// DefaultWatchdogInterval is the default interval between checks performed by watchdogs.
	DefaultWatchdogInterval = 30 * time.Second
	// DefaultWatchdogTimeout is the default timeout for checks performed by watchdogs.
	DefaultWatchdogTimeout = 2 * time.Minute
	// DefaultWatchdogTTL is the default watchdog TTL.
	DefaultWatchdogTTL = 10 * time.Minute
)

Functions

func GetOwnerCheckResultAndContext

func GetOwnerCheckResultAndContext(ctx context.Context, c client.Client, namespace, shootName, key string) (bool, context.Context, func(), error)

GetOwnerCheckResultAndContext returns the result and context from the watchdog for the given namespace managed by the default owner check WatchdogManager.

Types

type ChartRendererContext

type ChartRendererContext struct {
	RESTConfigContext
	// contains filtered or unexported fields
}

ChartRendererContext extends the RESTConfigContext to additionally provide a chart renderer

func NewChartRendererContext

func NewChartRendererContext(factory chartrenderer.Factory) ChartRendererContext

NewChartRendererContext creates a new chart renderer context using a dedicated factory for the renderer,

func (*ChartRendererContext) ChartRenderer

func (cc *ChartRendererContext) ChartRenderer() chartrenderer.Interface

ChartRenderer returns the chart renderer of the context

func (*ChartRendererContext) InjectConfig

func (cc *ChartRendererContext) InjectConfig(config *rest.Config) error

InjectConfig injects the given REST config into the context and creates an appropriate chart renderer

type Checker

type Checker interface {
	// Check checks that a certain condition is true.
	Check(ctx context.Context) (bool, error)
}

Checker checks if a certain condition is true.

func NewOwnerChecker

func NewOwnerChecker(ownerName, ownerID string, resolver Resolver, logger logr.Logger) Checker

NewOwnerChecker returns a Checker that checks if the given owner domain name resolves to the given owner ID, using the given resolver and logger.

type CheckerFactory

type CheckerFactory interface {
	// NewChecker creates a new Checker using the given context, client, namespace, and shoot name.
	NewChecker(ctx context.Context, c client.Client, namespace, shootName string) (Checker, error)
}

CheckerFactory creates Checker instances.

func NewOwnerCheckerFactory

func NewOwnerCheckerFactory(resolver Resolver, logger logr.Logger) CheckerFactory

NewOwnerCheckerFactory creates a new CheckerFactory that uses NewOwnerChecker to create Checker instances.

type ClientContext

type ClientContext struct {
	// contains filtered or unexported fields
}

ClientContext bundles the feature of providing injected scheme and client for the controller runtime. Additionally it offers a decoder using the scheme.

func NewClientContext

func NewClientContext(client client.Client, scheme *runtime.Scheme, decoder runtime.Decoder) ClientContext

NewClientContext offers the possibility to create a ClientContext without injection.

func (*ClientContext) Client

func (cc *ClientContext) Client() client.Client

Client returns the rest client of the context

func (*ClientContext) Decoder

func (cc *ClientContext) Decoder() runtime.Decoder

Decoder returns a decoder for the scheme of the context

func (*ClientContext) InjectClient

func (cc *ClientContext) InjectClient(client client.Client) error

InjectClient injects the given client into the context.

func (*ClientContext) InjectScheme

func (cc *ClientContext) InjectScheme(scheme *runtime.Scheme) error

InjectScheme injects the given scheme into the valuesProvider.

func (*ClientContext) Scheme

func (cc *ClientContext) Scheme() *runtime.Scheme

Scheme returns the scheme of the context

type RESTConfigContext

type RESTConfigContext struct {
	ClientContext
	// contains filtered or unexported fields
}

RESTConfigContext extends the ClientContext with the REST config usable to create more specific clients.

func (*RESTConfigContext) InjectConfig

func (cc *RESTConfigContext) InjectConfig(config *rest.Config) error

InjectConfig injects the given REST config into the context.

func (*RESTConfigContext) RESTConfig

func (cc *RESTConfigContext) RESTConfig() *rest.Config

RESTConfig returns the rest config of the context

type Resolver

type Resolver interface {
	// LookupTXT returns the DNS TXT records for the given domain name.
	LookupTXT(ctx context.Context, name string) ([]string, error)
}

Resolver looks up domain names and returns the corresponding DNS records.

type Watchdog

type Watchdog interface {
	// Start starts a goroutine that regularly checks if a certain condition is true.
	// If the check fails or returns false, it cancels all contexts.
	Start(ctx context.Context)
	// Stop stops the goroutine started by Start.
	Stop()
	// AddContext adds the given context to this watchdog mapped to the given key,
	// and returns a new context that will be cancelled if the condition check fails or returns false.
	// It returns true if the first context has been added, false otherwise.
	AddContext(ctx context.Context, key string) (context.Context, bool)
	// RemoveContext removes the context mapped to the given key from this watchdog.
	// It returns true if the last context has been removed, false otherwise.
	RemoveContext(key string) bool
	// Result returns the result of the last condition check.
	Result() (bool, error)
}

Watchdog manages a goroutine that regularly checks if a certain condition is true, and if the check fails or returns false, cancels multiple previously added contexts.

func NewCheckerWatchdog

func NewCheckerWatchdog(checker Checker, interval, timeout time.Duration, clock clock.Clock, logger logr.Logger) Watchdog

NewCheckerWatchdog creates a new Watchdog that checks if the condition checked by the given checker is true every given interval, using the given clock and logger.

type WatchdogFactory

type WatchdogFactory interface {
	// NewWatchdog creates a new Watchdog using the given context, client, namespace, and shoot name.
	NewWatchdog(ctx context.Context, c client.Client, namespace, shootName string) (Watchdog, error)
}

WatchdogFactory creates Watchdog instances.

func NewCheckerWatchdogFactory

func NewCheckerWatchdogFactory(checkerFactory CheckerFactory, interval, timeout time.Duration, clock clock.Clock, logger logr.Logger) WatchdogFactory

NewCheckerWatchdogFactory creates a new WatchdogFactory that uses NewCheckerWatchdog to create Watchdog instances.

type WatchdogManager

type WatchdogManager interface {
	// GetResultAndContext returns the result and context from the watchdog for the given namespace.
	// If the watchdog does not exist yet, it is created using the given context, client, namespace, and shoot name.
	// If the watchdog result is true, the given context is added to the watchdog mapped to the given key,
	// and a cleanup function for properly removing it is also returned.
	GetResultAndContext(ctx context.Context, c client.Client, namespace, shootName, key string) (bool, context.Context, func(), error)
}

WatchdogManager manages Watchdog instances for multiple namespaces.

func GetDefaultOwnerCheckWatchdogManager

func GetDefaultOwnerCheckWatchdogManager() WatchdogManager

GetDefaultOwnerCheckWatchdogManager returns the default owner check WatchdogManager.

func NewWatchdogManager

func NewWatchdogManager(watchdogFactory WatchdogFactory, ttl time.Duration, clk clock.Clock, logger logr.Logger) WatchdogManager

NewWatchdogManager creates a new WatchdogManager using the given watchdog factory, ttl, and logger.