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 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 (
	OrchestrationStatusStarting      = "starting"
	OrchestrationStatusComputingDiff = "computingDiff"
	OrchestrationStatusOrchestrating = "orchestrating"
	OrchestrationStatusCompleted     = "completed"
	OrchestrationStatusFailed        = "failed"
)

Functions

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

	HostNetwork bool
	// 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,
	hostNetwork bool,
	resources v1.ResourceRequirements,
	ownerRef metav1.OwnerReference,
) *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{})

Run 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"`
	Message string    `json:"message"`
}