controllers

Documentation

Index

• Variables
• type Adaptor
• type AdaptorK8s
  • func (k8s *AdaptorK8s) Reconcile(r *AntreaInstallReconciler, request ctrl.Request) (reconcile.Result, error)
  • func (k8s *AdaptorK8s) SetupWithManager(r *AntreaInstallReconciler, mgr ctrl.Manager) error
  • func (a *AdaptorK8s) UpdateStatusManagerAndSharedInfo(r *AntreaInstallReconciler, objs []*uns.Unstructured, ...) error
• type AdaptorOc
  • func (oc *AdaptorOc) Reconcile(r *AntreaInstallReconciler, request ctrl.Request) (reconcile.Result, error)
  • func (oc *AdaptorOc) SetupWithManager(r *AntreaInstallReconciler, mgr ctrl.Manager) error
  • func (a *AdaptorOc) UpdateStatusManagerAndSharedInfo(r *AntreaInstallReconciler, objs []*uns.Unstructured, ...) error
• type AntreaInstallReconciler
  • func New(mgr ctrl.Manager, statusManager *statusmanager.StatusManager, ...) (*AntreaInstallReconciler, error)
  • func (r *AntreaInstallReconciler) Reconcile(cxt context.Context, request ctrl.Request) (reconcile.Result, error)
  • func (r *AntreaInstallReconciler) SetupWithManager(mgr ctrl.Manager) error
• type PodReconciler
  • func (r *PodReconciler) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
  • func (r *PodReconciler) SetupWithManager(mgr ctrl.Manager) error

Variables

var ResyncPeriod = 2 * time.Minute

The periodic resync interval. We will re-run the reconciliation logic, even if the NCP configuration hasn't changed.

Types

type Adaptor

type Adaptor interface {
	SetupWithManager(r *AntreaInstallReconciler, mgr ctrl.Manager) error
	Reconcile(r *AntreaInstallReconciler, request ctrl.Request) (reconcile.Result, error)
	UpdateStatusManagerAndSharedInfo(r *AntreaInstallReconciler, objs []*uns.Unstructured, clusterConfig *configv1.Network) error
}

type AdaptorK8s

type AdaptorK8s struct {
	Config configutil.Config
}

func (*AdaptorK8s) Reconcile

func (k8s *AdaptorK8s) Reconcile(r *AntreaInstallReconciler, request ctrl.Request) (reconcile.Result, error)

func (*AdaptorK8s) SetupWithManager

func (k8s *AdaptorK8s) SetupWithManager(r *AntreaInstallReconciler, mgr ctrl.Manager) error

func (*AdaptorK8s) UpdateStatusManagerAndSharedInfo

func (a *AdaptorK8s) UpdateStatusManagerAndSharedInfo(r *AntreaInstallReconciler, objs []*uns.Unstructured, clusterConfig *configv1.Network) error

type AdaptorOc

type AdaptorOc struct {
	Config configutil.Config
}

func (*AdaptorOc) Reconcile

func (oc *AdaptorOc) Reconcile(r *AntreaInstallReconciler, request ctrl.Request) (reconcile.Result, error)

func (*AdaptorOc) SetupWithManager

func (oc *AdaptorOc) SetupWithManager(r *AntreaInstallReconciler, mgr ctrl.Manager) error

func (*AdaptorOc) UpdateStatusManagerAndSharedInfo

func (a *AdaptorOc) UpdateStatusManagerAndSharedInfo(r *AntreaInstallReconciler, objs []*uns.Unstructured, clusterConfig *configv1.Network) error

type AntreaInstallReconciler

type AntreaInstallReconciler struct {
	Client cnoclient.Client
	Log    logr.Logger
	Scheme *runtime.Scheme
	Status *statusmanager.StatusManager
	Mapper meta.RESTMapper

	Adaptor

	SharedInfo           *sharedinfo.SharedInfo
	AppliedClusterConfig *configv1.Network
	AppliedOperConfig    *operatorv1.AntreaInstall
}

AntreaInstallReconciler reconciles a AntreaInstall object

func New

func New(mgr ctrl.Manager, statusManager *statusmanager.StatusManager, info *sharedinfo.SharedInfo, cli cnoclient.Client) (*AntreaInstallReconciler, error)

func (*AntreaInstallReconciler) Reconcile

func (r *AntreaInstallReconciler) Reconcile(cxt context.Context, request ctrl.Request) (reconcile.Result, error)

func (*AntreaInstallReconciler) SetupWithManager

func (r *AntreaInstallReconciler) SetupWithManager(mgr ctrl.Manager) error

type PodReconciler

type PodReconciler struct {
	Client     cnocient.Client
	Log        logr.Logger
	Scheme     *runtime.Scheme
	Status     *statusmanager.StatusManager
	SharedInfo *sharedinfo.SharedInfo
}

PodReconciler reconciles a Pod object

func (*PodReconciler) Reconcile

func (r *PodReconciler) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

Reconcile updates the ClusterOperator.Status to match the current state of the watched Deployments/DaemonSets

func (*PodReconciler) SetupWithManager

func (r *PodReconciler) SetupWithManager(mgr ctrl.Manager) error