controller

Documentation

Index

• type ConfigReconciler
  • func NewConfigReconciler(karydiaConfig v1alpha1.KarydiaConfig, karydiaControllers []ControllerInterface, ...) *ConfigReconciler
  • func (reconciler *ConfigReconciler) Run(threadiness int, stopCh <-chan struct{}) error
  • func (reconciler *ConfigReconciler) UpdateConfig(karydiaConfig v1alpha1.KarydiaConfig) error
• type ControllerInterface
• type NetworkpolicyReconciler
  • func NewNetworkpolicyReconciler(kubeclientset kubernetes.Interface, karydiaClientset versioned.Interface, ...) *NetworkpolicyReconciler
  • func (reconciler *NetworkpolicyReconciler) Run(threadiness int, stopCh <-chan struct{}) error
  • func (reconciler *NetworkpolicyReconciler) UpdateConfig(karydiaConfig v1alpha1.KarydiaConfig) error
• type Setting

Types

type ConfigReconciler

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

reconciler (controller) struct

func NewConfigReconciler

func NewConfigReconciler(
	karydiaConfig v1alpha1.KarydiaConfig,
	karydiaControllers []ControllerInterface,
	karydiaClientset versioned.Interface,
	karydiaConfigInformer v1alpha12.KarydiaConfigInformer,
) *ConfigReconciler

reconciler (controller) setup

func (*ConfigReconciler) Run

func (reconciler *ConfigReconciler) Run(threadiness int, stopCh <-chan struct{}) error

set up event handlers for types we are interested in, syncing informer caches and starting workers It will block until the channel is closed, at which point it will shutdown the workqueue and wait for workers to finish processing their current work items.

func (*ConfigReconciler) UpdateConfig

func (reconciler *ConfigReconciler) UpdateConfig(karydiaConfig v1alpha1.KarydiaConfig) error

update actual config

type ControllerInterface

type ControllerInterface interface {
	UpdateConfig(karydiaConfig v1alpha1.KarydiaConfig) error
}

type NetworkpolicyReconciler

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

func NewNetworkpolicyReconciler

func NewNetworkpolicyReconciler(
	kubeclientset kubernetes.Interface,
	karydiaClientset versioned.Interface,
	networkpolicyInformer networkpolicyInformer.NetworkPolicyInformer, namespaceInformer namespaceInformer.NamespaceInformer,
	defaultNetworkPolicies map[string]*networkingv1.NetworkPolicy, defaultEnforcement bool, defaultNetworkPolicyName string, defaultNetworkPolicyExcludes []string) *NetworkpolicyReconciler

func (*NetworkpolicyReconciler) Run

func (reconciler *NetworkpolicyReconciler) Run(threadiness int, stopCh <-chan struct{}) error

func (*NetworkpolicyReconciler) UpdateConfig

func (reconciler *NetworkpolicyReconciler) UpdateConfig(karydiaConfig v1alpha1.KarydiaConfig) error

type Setting

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