node

Documentation

Index

• func Register(ctx context.Context, nodes ctllonghornv1.NodeController, ...) error
• type Controller
  • func (c *Controller) OnNodeChange(_ string, node *longhornv1.Node) (*longhornv1.Node, error)
  • func (c *Controller) OnNodeDelete(_ string, node *longhornv1.Node) (*longhornv1.Node, error)

Functions

func Register

func Register(ctx context.Context, nodes ctllonghornv1.NodeController, bds ctldiskv1.BlockDeviceController, opt *option.Option) error

Register register the longhorn node CRD controller

Types

type Controller

type Controller struct {
	BlockDevices     ctldiskv1.BlockDeviceController
	BlockDeviceCache ctldiskv1.BlockDeviceCache
	Nodes            ctllonghornv1.NodeController
	// contains filtered or unexported fields
}

func (*Controller) OnNodeChange

func (c *Controller) OnNodeChange(_ string, node *longhornv1.Node) (*longhornv1.Node, error)

OnChange watch the node CR on change and sync up to block device CR

func (*Controller) OnNodeDelete

func (c *Controller) OnNodeDelete(_ string, node *longhornv1.Node) (*longhornv1.Node, error)

OnNodeDelete watch the node CR on remove and delete node related block devices