nodereconciler

package
v1.0.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 30, 2026 License: MIT Imports: 27 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Cell = cell.Module(
	"node-controller",
	"Node Controller monitors Node CRUD events",
	cell.Provide(newNodeController),

	cell.Invoke(func(l logrus.FieldLogger, nr *NodeReconciler, ctrlManager ctrl.Manager) error {
		l.Info("Setting up node controller with manager")
		if err := nr.SetupWithManager(ctrlManager); err != nil {
			l.Errorf("failed to setup node controller with manager: %v", err)
			return errors.Wrap(err, "failed to setup node controller with manager")
		}
		return nil
	}),
)

Functions

This section is empty.

Types

type NodeReconciler 

type NodeReconciler struct {
	client.Client
	// contains filtered or unexported fields
}

NodeReconciler reconciles a Node object. This is pretty basic for now, need fine tuning, scale test, etc.

func (*NodeReconciler) ClusterSizeDependantInterval added in v0.0.30 

func (r *NodeReconciler) ClusterSizeDependantInterval(time.Duration) time.Duration

The following methods are stubs for the NodeManager interface. It is done because the hubble requires NodeManager interface as a dependency. However, we don't need to implement all the methods. TODO: make Notifier interface as dependency for the hubble instead of NodeManager on upstream.

func (*NodeReconciler) Enqueue added in v0.0.30 

func (r *NodeReconciler) Enqueue(*types.Node)

func (*NodeReconciler) GetNodeIdentities added in v0.0.30 

func (r *NodeReconciler) GetNodeIdentities() []types.Identity

func (*NodeReconciler) GetNodes added in v0.0.30 

func (r *NodeReconciler) GetNodes() map[types.Identity]types.Node

func (*NodeReconciler) MeshNodeSync added in v0.0.30 

func (r *NodeReconciler) MeshNodeSync()

func (*NodeReconciler) NodeDeleted added in v0.0.30 

func (r *NodeReconciler) NodeDeleted(types.Node)

func (*NodeReconciler) NodeSync added in v0.0.30 

func (r *NodeReconciler) NodeSync()

func (*NodeReconciler) NodeUpdated added in v0.0.30 

func (r *NodeReconciler) NodeUpdated(types.Node)

func (*NodeReconciler) Reconcile 

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

+kubebuilder:rbac:groups="",resources=nodes,verbs=get;list

func (*NodeReconciler) SetPrefixClusterMutatorFn added in v0.0.30 

func (r *NodeReconciler) SetPrefixClusterMutatorFn(func(*types.Node) []cmtypes.PrefixClusterOpts)

func (*NodeReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

func (*NodeReconciler) StartNeighborRefresh added in v0.0.30 

func (r *NodeReconciler) StartNeighborRefresh(datapath.NodeNeighbors)

func (*NodeReconciler) StartNodeNeighborLinkUpdater added in v0.0.30 

func (r *NodeReconciler) StartNodeNeighborLinkUpdater(datapath.NodeNeighbors)

func (*NodeReconciler) Subscribe 

func (r *NodeReconciler) Subscribe(nh datapath.NodeHandler)

func (*NodeReconciler) Unsubscribe 

func (r *NodeReconciler) Unsubscribe(nh datapath.NodeHandler)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.