controller

Documentation

Index

• type NodeReconciler
  • func NewNodeReconciler(client client.Client, log logr.Logger, elected <-chan struct{}, ...) *NodeReconciler
  • func (r *NodeReconciler) HealthzChecker(_ *http.Request) error
  • func (r *NodeReconciler) ReadyChecker(_ *http.Request) error
  • func (r *NodeReconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)
  • func (r *NodeReconciler) StartUpdater(ctx context.Context, updateFunc updater.NodeRoutesUpdater, ...)

Types

type NodeReconciler

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

NodeReconciler watches Nodes for pod CIDRs to update route table(s)

func NewNodeReconciler

func NewNodeReconciler(
	client client.Client,
	log logr.Logger,
	elected <-chan struct{},
	recorder record.EventRecorder,
) *NodeReconciler

NewNodeReconciler creates a NodeReconciler instance

func (*NodeReconciler) HealthzChecker

func (r *NodeReconciler) HealthzChecker(_ *http.Request) error

func (*NodeReconciler) ReadyChecker

func (r *NodeReconciler) ReadyChecker(_ *http.Request) error

func (*NodeReconciler) Reconcile

func (r *NodeReconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)

Reconcile extracts pod cidrs from nodes

func (*NodeReconciler) StartUpdater

func (r *NodeReconciler) StartUpdater(ctx context.Context, updateFunc updater.NodeRoutesUpdater,
	tickPeriod, syncPeriod, maxDelayOnFailure time.Duration)

StartUpdater starts background go routine to check for changed routes calculated by watching nodes