osd

Documentation

Index

• func GetCephVolumeLVMOSDs(context *clusterd.Context, clusterInfo *client.ClusterInfo, ...) ([]oposd.OSDInfo, error)
• func GetCephVolumeRawOSDs(context *clusterd.Context, clusterInfo *client.ClusterInfo, ...) ([]oposd.OSDInfo, error)
• func Provision(context *clusterd.Context, agent *OsdAgent, ...) error
• func RemoveOSDs(context *clusterd.Context, clusterInfo *client.ClusterInfo, ...) error
• func StartOSD(context *clusterd.Context, osdType, osdID, osdUUID, lvPath string, ...) error
• func UpdateLVMConfig(context *clusterd.Context, onPVC, lvBackedPV bool) error
• type DesiredDevice
• type Device
• type DeviceOsdIDEntry
• type DeviceOsdMapping
  • func (m *DeviceOsdMapping) String() string
• type NSEnter
  • func NewNsenter(context *clusterd.Context, binary string, binaryArgs []string) *NSEnter
• type OsdAgent
  • func NewAgent(context *clusterd.Context, devices []DesiredDevice, metadataDevice string, ...) *OsdAgent

Functions

func GetCephVolumeLVMOSDs

func GetCephVolumeLVMOSDs(context *clusterd.Context, clusterInfo *client.ClusterInfo, cephfsid, lv string, skipLVRelease, lvBackedPV bool) ([]oposd.OSDInfo, error)

GetCephVolumeLVMOSDs list OSD prepared with lvm mode

func GetCephVolumeRawOSDs

func GetCephVolumeRawOSDs(context *clusterd.Context, clusterInfo *client.ClusterInfo, cephfsid, block, metadataBlock, walBlock string, lvBackedPV, skipDeviceClass bool) ([]oposd.OSDInfo, error)

GetCephVolumeRawOSDs list OSD prepared with raw mode

func Provision

func Provision(context *clusterd.Context, agent *OsdAgent, crushLocation, topologyAffinity string) error

Provision provisions an OSD

func RemoveOSDs

func RemoveOSDs(context *clusterd.Context, clusterInfo *client.ClusterInfo, osdsToRemove []string) error

RemoveOSDs purges a list of OSDs from the cluster

func StartOSD

func StartOSD(context *clusterd.Context, osdType, osdID, osdUUID, lvPath string, pvcBackedOSD, lvBackedPV bool, cephArgs []string) error

StartOSD starts an OSD on a device that was provisioned by ceph-volume

func UpdateLVMConfig

func UpdateLVMConfig(context *clusterd.Context, onPVC, lvBackedPV bool) error

UpdateLVMConfig updates the lvm.conf file

Types

type DesiredDevice

type DesiredDevice struct {
	Name               string
	OSDsPerDevice      int
	MetadataDevice     string
	DatabaseSizeMB     int
	DeviceClass        string
	InitialWeight      string
	IsFilter           bool
	IsDevicePathFilter bool
}

DesiredDevice keeps track of the desired settings for a device

type Device

type Device struct {
	Name   string `json:"name"`
	NodeID string `json:"nodeId"`
	Dir    bool   `json:"bool"`
}

Device is a device

type DeviceOsdIDEntry

type DeviceOsdIDEntry struct {
	Data                  int           // OSD ID that has data stored here
	Metadata              []int         // OSD IDs (multiple) that have metadata stored here
	Config                DesiredDevice // Device specific config options
	PersistentDevicePaths []string
	DeviceInfo            *sys.LocalDisk // low-level info about the device
}

DeviceOsdIDEntry represents the details of an OSD

type DeviceOsdMapping

type DeviceOsdMapping struct {
	Entries map[string]*DeviceOsdIDEntry // device name to OSD ID mapping entry
}

DeviceOsdMapping represents the mapping of an OSD on disk

func (*DeviceOsdMapping) String

func (m *DeviceOsdMapping) String() string

type NSEnter

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

NSEnter is an nsenter object

func NewNsenter

func NewNsenter(context *clusterd.Context, binary string, binaryArgs []string) *NSEnter

NewNsenter returns an instance of the NSEnter object

type OsdAgent

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

OsdAgent represents the OSD struct of an agent

func NewAgent

func NewAgent(context *clusterd.Context, devices []DesiredDevice, metadataDevice string, forceFormat bool,
	storeConfig config.StoreConfig, clusterInfo *cephclient.ClusterInfo, nodeName string, kv *k8sutil.ConfigMapKVStore, pvcBacked bool) *OsdAgent

NewAgent is the instantiation of the OSD agent