osd

Documentation

Overview

Package osd for the Ceph OSDs.

Package osd for the Ceph OSDs.

Package osd for the Ceph OSDs.

Package osd for the Ceph OSDs.

Index

• Constants
• func GetValidVolumeSources(clientset kubernetes.Interface, namespace string, ...) (validVolumes []rookalpha.VolumeSource, err error)
• func IsRemovingNode(devices string) bool
• func UpdateNodeStatus(kv *k8sutil.ConfigMapKVStore, node string, status OrchestrationStatus) error
• type Cluster
  • func New(clusterInfo *cephconfig.ClusterInfo, context *clusterd.Context, ...) *Cluster
  • func (c *Cluster) Start() error
• type Monitor
  • func NewMonitor(context *clusterd.Context, clusterName string) *Monitor
  • func (m *Monitor) Start(stopCh chan struct{})
• type OSDInfo
• type OrchestrationStatus

Constants

const (
	// AppName is the "app" label on osd pods
	AppName = "rook-ceph-osd"
	// FailureDomainKey is the label key whose value is the failure domain of the OSD
	FailureDomainKey = "failure-domain"

	OsdIdLabelKey = "ceph-osd-id"
)

const (
	CephDeviceSetLabelKey      = "ceph.rook.io/DeviceSet"
	CephSetIndexLabelKey       = "ceph.rook.io/setIndex"
	CephDeviceSetPVCIDLabelKey = "ceph.rook.io/DeviceSetPVCId"
	OSDOverPVCLabelKey         = "ceph.rook.io/pvc"
)

const (
	OrchestrationStatusStarting      = "starting"
	OrchestrationStatusComputingDiff = "computingDiff"
	OrchestrationStatusOrchestrating = "orchestrating"
	OrchestrationStatusCompleted     = "completed"
	OrchestrationStatusFailed        = "failed"
)

Functions

func GetValidVolumeSources

func GetValidVolumeSources(clientset kubernetes.Interface, namespace string, volumeSources []rookalpha.VolumeSource) (validVolumes []rookalpha.VolumeSource, err error)

GetValidVolumeSources returns all volumes that has an OSDDeployment

func IsRemovingNode

func IsRemovingNode(devices string) bool

func UpdateNodeStatus

func UpdateNodeStatus(kv *k8sutil.ConfigMapKVStore, node string, status OrchestrationStatus) error

Types

type Cluster

type Cluster struct {
	Namespace string

	Keyring string

	DesiredStorage rookalpha.StorageScopeSpec // user-defined storage scope spec
	ValidStorage   rookalpha.StorageScopeSpec // valid subset of `Storage`, computed at runtime

	Network cephv1.NetworkSpec
	// contains filtered or unexported fields
}

Cluster keeps track of the OSDs

func New

func New(
	clusterInfo *cephconfig.ClusterInfo,
	context *clusterd.Context,
	namespace string,
	rookVersion string,
	cephVersion cephv1.CephVersionSpec,
	storageSpec rookalpha.StorageScopeSpec,
	dataDirHostPath string,
	placement rookalpha.Placement,
	annotations rookalpha.Annotations,
	network cephv1.NetworkSpec,
	resources v1.ResourceRequirements,
	ownerRef metav1.OwnerReference,
	isUpgrade bool,
) *Cluster

New creates an instance of the OSD manager

func (*Cluster) Start

func (c *Cluster) Start() error

Start the osd management

type Monitor

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

Monitor defines OSD process monitoring

func NewMonitor

func NewMonitor(context *clusterd.Context, clusterName string) *Monitor

NewMonitor instantiates OSD monitoring

func (*Monitor) Start

func (m *Monitor) Start(stopCh chan struct{})

Start runs monitoring logic for osds status at set intervals

type OSDInfo

type OSDInfo struct {
	ID                  int    `json:"id"`
	DataPath            string `json:"data-path"`
	Config              string `json:"conf"`
	Cluster             string `json:"cluster"`
	KeyringPath         string `json:"keyring-path"`
	UUID                string `json:"uuid"`
	Journal             string `json:"journal"`
	IsFileStore         bool   `json:"is-file-store"`
	IsDirectory         bool   `json:"is-directory"`
	DevicePartUUID      string `json:"device-part-uuid"`
	CephVolumeInitiated bool   `json:"ceph-volume-initiated"`
}

type OrchestrationStatus

type OrchestrationStatus struct {
	OSDs         []OSDInfo `json:"osds"`
	Status       string    `json:"status"`
	PvcBackedOSD bool      `json:"pvc-backed-osd"`
	Message      string    `json:"message"`
}