discover

Documentation

Overview

Package discover to discover devices on storage nodes.

Index

• func FreeDevices(context *clusterd.Context, nodeName, clusterName string) error
• func FreeDevicesByCluster(context *clusterd.Context, clusterName string) error
• 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) error

Functions

func FreeDevices

func FreeDevices(context *clusterd.Context, nodeName, clusterName string) error

FreeDevices frees up devices used by a cluster on a node.

func FreeDevicesByCluster

func FreeDevicesByCluster(context *clusterd.Context, clusterName string) error

FreeDevicesByCluster frees devices on all nodes that are used by the cluster

func GetAvailableDevices

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

GetAvailableDevices conducts outter 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) error

Start the discover