discover

Documentation

Overview

Package discover to discover devices on storage nodes.

Index

• func GetAvailableDevices(context *clusterd.Context, nodeName, clusterName string, ...) ([]rookalpha.Device, error)
• func ListDevices(context *clusterd.Context, namespace, nodeName string) (map[string][]sys.LocalDisk, error)
• func ListDevicesInUse(context *clusterd.Context, namespace, nodeName string) ([]sys.LocalDisk, error)
• type Discover
  • func New(clientset kubernetes.Interface) *Discover
  • func (d *Discover) Start(namespace, discoverImage, securityAccount string, useCephVolume bool) error

Functions

func GetAvailableDevices

func GetAvailableDevices(context *clusterd.Context, nodeName, clusterName string, devices []rookalpha.Device, filter string, useAllDevices bool) ([]rookalpha.Device, error)

GetAvailableDevices conducts outer join using input filters with free devices that a node has. It marks the devices from join result as in-use.

func ListDevices

func ListDevices(context *clusterd.Context, namespace, nodeName string) (map[string][]sys.LocalDisk, error)

ListDevices lists all devices discovered on all nodes or specific node if node name is provided.

func ListDevicesInUse

func ListDevicesInUse(context *clusterd.Context, namespace, nodeName string) ([]sys.LocalDisk, error)

ListDevicesInUse lists all devices on a node that are already used by existing clusters.

Types

type Discover

type Discover struct {
	// contains filtered or unexported fields
}

Discover reference to be deployed

func New

func New(clientset kubernetes.Interface) *Discover

New creates an instance of Discover

func (*Discover) Start

func (d *Discover) Start(namespace, discoverImage, securityAccount string, useCephVolume bool) error

Start the discover