internal

Documentation

Index

• Variables
• func CheckCacheSync[T comparable](logger logr.Logger, status map[T]bool) bool
• func CreateClientConfig(logger logr.Logger) *rest.Config
• func CreateDClient(logger logr.Logger, ctx context.Context, dyn dynamic.Interface, ...) dclient.Interface
• func CreateDynamicClient(logger logr.Logger, opts ...dyn.NewOption) dynamic.Interface
• func CreateKubernetesClient(logger logr.Logger, opts ...kube.NewOption) kubernetes.Interface
• func CreateKyvernoClient(logger logr.Logger, opts ...kyverno.NewOption) versioned.Interface
• func CreateMetadataClient(logger logr.Logger, opts ...meta.NewOption) metadata.Interface
• func GetMetricsConfiguration(logger logr.Logger, client kubernetes.Interface) config.MetricsConfiguration
• func InitFlags(config Configuration)
• func ParseFlags(config Configuration)
• func Setup(name string) (context.Context, logr.Logger, metrics.MetricsConfigManager, context.CancelFunc)
• func SetupLogger() logr.Logger
• func SetupMaxProcs(logger logr.Logger) func()
• func SetupMetrics(ctx context.Context, logger logr.Logger, kubeClient kubernetes.Interface) (metrics.MetricsConfigManager, context.CancelFunc)
• func SetupProfiling(logger logr.Logger)
• func SetupSignals(logger logr.Logger) (context.Context, context.CancelFunc)
• func SetupTracing(logger logr.Logger, name string, kubeClient kubernetes.Interface) context.CancelFunc
• func ShowVersion(logger logr.Logger)
• func StartInformers[T startable](ctx context.Context, informers ...T)
• func StartInformersAndWaitForCacheSync(ctx context.Context, logger logr.Logger, informers ...informer) bool
• func WaitForCacheSync(ctx context.Context, logger logr.Logger, informers ...informer) bool
• type Configuration
  • func NewConfiguration(options ...ConfigurationOption) Configuration
• type ConfigurationOption
  • func WithFlagSets(flagsets ...*flag.FlagSet) ConfigurationOption
  • func WithKubeconfig() ConfigurationOption
  • func WithMetrics() ConfigurationOption
  • func WithProfiling() ConfigurationOption
  • func WithTracing() ConfigurationOption
• type Controller
  • func NewController(name string, c controllers.Controller, w int) Controller

Variables

var Context = context.Background()

Functions

func CheckCacheSync

func CheckCacheSync[T comparable](logger logr.Logger, status map[T]bool) bool

func CreateClientConfig

func CreateClientConfig(logger logr.Logger) *rest.Config

func CreateDClient

func CreateDClient(logger logr.Logger, ctx context.Context, dyn dynamic.Interface, kube kubernetes.Interface, resync time.Duration) dclient.Interface

func CreateDynamicClient

func CreateDynamicClient(logger logr.Logger, opts ...dyn.NewOption) dynamic.Interface

func CreateKubernetesClient

func CreateKubernetesClient(logger logr.Logger, opts ...kube.NewOption) kubernetes.Interface

func CreateKyvernoClient

func CreateKyvernoClient(logger logr.Logger, opts ...kyverno.NewOption) versioned.Interface

func CreateMetadataClient

func CreateMetadataClient(logger logr.Logger, opts ...meta.NewOption) metadata.Interface

func GetMetricsConfiguration

func GetMetricsConfiguration(logger logr.Logger, client kubernetes.Interface) config.MetricsConfiguration

func InitFlags

func InitFlags(config Configuration)

func ParseFlags

func ParseFlags(config Configuration)

func Setup

func Setup(name string) (context.Context, logr.Logger, metrics.MetricsConfigManager, context.CancelFunc)

func SetupLogger

func SetupLogger() logr.Logger

func SetupMaxProcs

func SetupMaxProcs(logger logr.Logger) func()

func SetupMetrics

func SetupMetrics(ctx context.Context, logger logr.Logger, kubeClient kubernetes.Interface) (metrics.MetricsConfigManager, context.CancelFunc)

func SetupProfiling

func SetupProfiling(logger logr.Logger)

func SetupSignals

func SetupSignals(logger logr.Logger) (context.Context, context.CancelFunc)

func SetupTracing

func SetupTracing(logger logr.Logger, name string, kubeClient kubernetes.Interface) context.CancelFunc

func ShowVersion

func ShowVersion(logger logr.Logger)

func StartInformers

func StartInformers[T startable](ctx context.Context, informers ...T)

func StartInformersAndWaitForCacheSync

func StartInformersAndWaitForCacheSync(ctx context.Context, logger logr.Logger, informers ...informer) bool

func WaitForCacheSync

func WaitForCacheSync(ctx context.Context, logger logr.Logger, informers ...informer) bool

Types

type Configuration

type Configuration interface {
	UsesMetrics() bool
	UsesTracing() bool
	UsesProfiling() bool
	UsesKubeconfig() bool
	FlagSets() []*flag.FlagSet
}

func NewConfiguration

func NewConfiguration(options ...ConfigurationOption) Configuration

type ConfigurationOption

type ConfigurationOption func(c *configuration)

func WithFlagSets

func WithFlagSets(flagsets ...*flag.FlagSet) ConfigurationOption

func WithKubeconfig

func WithKubeconfig() ConfigurationOption

func WithMetrics

func WithMetrics() ConfigurationOption

func WithProfiling

func WithProfiling() ConfigurationOption

func WithTracing

func WithTracing() ConfigurationOption

type Controller

type Controller interface {
	Run(context.Context, logr.Logger, *sync.WaitGroup)
}

func NewController

func NewController(name string, c controllers.Controller, w int) Controller