endpoint

Documentation

Index

• func Register(ctx context.Context, endpoint ctlcorev1.EndpointsController, ...) error
• type Controller
  • func (c *Controller) OnEndpointChange(_ string, endpoint *corev1.Endpoints) (*corev1.Endpoints, error)

Functions

func Register

func Register(ctx context.Context, endpoint ctlcorev1.EndpointsController, netfilesystems ctlntefsv1.NetworkFilesystemController, serviceClient ctlcorev1.ServiceController, opt *utils.Option) error

Register register the longhorn node CRD controller

Types

type Controller

type Controller struct {
	EndpointCache     ctlcorev1.EndpointsCache
	Endpoints         ctlcorev1.EndpointsController
	NetworkFSCache    ctlntefsv1.NetworkFilesystemCache
	NetworkFilsystems ctlntefsv1.NetworkFilesystemController
	// contains filtered or unexported fields
}

func (*Controller) OnEndpointChange

func (c *Controller) OnEndpointChange(_ string, endpoint *corev1.Endpoints) (*corev1.Endpoints, error)

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