cnr

Documentation

Index

• type CNRFetcher
  • func NewCachedCNRFetcher(nodeName string, ttl time.Duration, ...) CNRFetcher
• type CNRFetcherStub
  • func (c *CNRFetcherStub) GetCNR(context.Context) (*v1alpha1.CustomNodeResource, error)
  • func (c *CNRFetcherStub) RegisterNotifier(_ string, _ CNRNotifier) error
  • func (c *CNRFetcherStub) UnregisterNotifier(_ string) error
• type CNRNotifier
• type CNRNotifierStub
  • func (C CNRNotifierStub) OnCNRStatusUpdate(cnr *v1alpha1.CustomNodeResource)
  • func (C CNRNotifierStub) OnCNRUpdate(cnr *v1alpha1.CustomNodeResource)

Types

type CNRFetcher

type CNRFetcher interface {
	// GetCNR returns those latest custom node resources metadata.
	GetCNR(ctx context.Context) (*nodev1alpha1.CustomNodeResource, error)

	// RegisterNotifier registers a notifier to be notified when CNR is updated.
	RegisterNotifier(name string, notifier CNRNotifier) error

	// UnregisterNotifier unregisters a notifier.
	UnregisterNotifier(name string) error
}

CNRFetcher is used to get CNR information.

func NewCachedCNRFetcher

func NewCachedCNRFetcher(nodeName string, ttl time.Duration, client v1alpha1.CustomNodeResourceInterface) CNRFetcher

type CNRFetcherStub

type CNRFetcherStub struct {
	CNR *v1alpha1.CustomNodeResource
}

func (*CNRFetcherStub) GetCNR

func (c *CNRFetcherStub) GetCNR(context.Context) (*v1alpha1.CustomNodeResource, error)

func (*CNRFetcherStub) RegisterNotifier

func (c *CNRFetcherStub) RegisterNotifier(_ string, _ CNRNotifier) error

func (*CNRFetcherStub) UnregisterNotifier

func (c *CNRFetcherStub) UnregisterNotifier(_ string) error

type CNRNotifier

type CNRNotifier interface {
	// OnCNRUpdate is called when CNR is updated.
	OnCNRUpdate(cnr *nodev1alpha1.CustomNodeResource)

	// OnCNRStatusUpdate is called when CNR status is updated.
	OnCNRStatusUpdate(cnr *nodev1alpha1.CustomNodeResource)
}

CNRNotifier is used to notify CNR update.

type CNRNotifierStub

type CNRNotifierStub struct{}

CNRNotifierStub is a stub implementation of CNRNotifier.

func (CNRNotifierStub) OnCNRStatusUpdate

func (C CNRNotifierStub) OnCNRStatusUpdate(cnr *v1alpha1.CustomNodeResource)

OnCNRStatusUpdate is called when CNR status is updated.

func (CNRNotifierStub) OnCNRUpdate

func (C CNRNotifierStub) OnCNRUpdate(cnr *v1alpha1.CustomNodeResource)

OnCNRUpdate is called when CNR is updated.