nodereconciler

package

v1.0.4 Latest Latest Go to latest Published: Feb 6, 2026 License: MIT Imports: 27 Imported by: 2

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/microsoft/retina

Links

Open Source Insights

Documentation ¶

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 (r *NodeReconciler) Subscribe(nh datapath.NodeHandler)

func (*NodeReconciler) Unsubscribe ¶

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL