controller

Documentation

Index

• type Manager
  • func NewManager(options Options) (Manager, error)
• type Options

Types

type Manager

type Manager interface {
	// GetClient returns a client.Client
	GetClient() client.Client

	// GetCache returns a cache.Cache
	GetCache() cache.Cache

	// Start all the registered controllers and blocks until the context is cancelled.
	// Returns an error if there is an error starting any controller.
	Start(ctx context.Context) error
}

Manager is responsible for managing node resources, including storage pools, disks, and processing-related resources.

func NewManager

func NewManager(options Options) (Manager, error)

NewManager returns a new Manager for creating Controllers.

type Options

type Options struct {
	// NodeName represents where the Manager is running
	NodeName string

	// Namespace
	Namespace string

	// K8sClient is used to perform CRUD operations on Kubernetes objects
	K8sClient client.Client

	// Cache is used to load Kubernetes objects
	Cache cache.Cache

	// Logger  is the logger that should be used by this manager.
	// If none is set, it defaults to log.Log global logger.
	Logger *log.Entry

	Recorder record.EventRecorder
}

Options are the arguments for creating a new Manager