osd

Documentation

Overview

Package osd for the Ceph OSDs.

Package osd for the Ceph OSDs.

Index

• Constants
• func IsRemovingNode(devices string) bool
• func UpdateOrchestrationStatusMap(clientset kubernetes.Interface, namespace string, node string, ...) error
• type Cluster
  • func New(context *clusterd.Context, namespace, version string, ...) *Cluster
  • func (c *Cluster) Start() error
• type OrchestrationStatus

Constants

const (
	OrchestrationStatusMapName       = "rook-ceph-osd-orchestration-status"
	OrchestrationStatusStarting      = "starting"
	OrchestrationStatusComputingDiff = "computingDiff"
	OrchestrationStatusOrchestrating = "orchestrating"
	OrchestrationStatusCompleted     = "completed"
	OrchestrationStatusFailed        = "failed"
)

Functions

func IsRemovingNode

func IsRemovingNode(devices string) bool

func UpdateOrchestrationStatusMap

func UpdateOrchestrationStatusMap(clientset kubernetes.Interface, namespace string, node string, status OrchestrationStatus) error

Types

type Cluster

type Cluster struct {
	Namespace string

	Keyring string
	Version string
	Storage rookalpha.StorageSpec

	HostNetwork bool
	// contains filtered or unexported fields
}

Cluster keeps track of the OSDs

func New

func New(context *clusterd.Context, namespace, version string, storageSpec rookalpha.StorageSpec, dataDirHostPath string,
	placement rookalpha.Placement, 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 OrchestrationStatus

type OrchestrationStatus struct {
	Status  string `json:"status"`
	Message string `json:"message"`
}