node

Documentation

Index

• type DiskManagerProvider
• type LocalRegistryProvider
• type Manager
  • func NewManager(options Options) (Manager, error)
• type Options
• type PoolManagerProvider
• type VolumeManagerProvider

Types

type DiskManagerProvider

type DiskManagerProvider func() disk.Manager

type LocalRegistryProvider

type LocalRegistryProvider func() registry.Manager

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

	// DiskManager returns a disk.Manager
	DiskManager() disk.Manager

	// VolumeManager returns a volume.Manager
	VolumeManager() volume.Manager

	// LocalRegistry returns a registry.Manager
	LocalRegistry() registry.Manager

	// PoolManager returns a pool.Manager
	PoolManager() pool.Manager
}

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 TBD.
	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

	// DiskTaskQueue is the queue stored LocalDisk objects
	DiskTaskQueue *common.TaskQueue

	// DiskClaimTaskQueue is the queue stored LocalDiskClaim objects
	DiskClaimTaskQueue *common.TaskQueue

	// DiskNodeTaskQueue is the queue stored LocalDiskNode objects
	DiskNodeTaskQueue *common.TaskQueue

	// 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

	// VolumeManagerProvider provides the manager for Volumes
	VolumeManagerProvider

	// DiskManagerProvider provides the manager for Disks
	DiskManagerProvider

	// LocalRegistryProvider provides the manager for node resources
	LocalRegistryProvider

	// PoolManagerProvider provides the manager for DiskPool
	PoolManagerProvider
}

Options are the arguments for creating a new Manager

type PoolManagerProvider

type PoolManagerProvider func() pool.Manager

type VolumeManagerProvider

type VolumeManagerProvider func() volume.Manager