osd

package

v1.1.2 Latest Latest Go to latest Published: Oct 2, 2019 License: Apache-2.0 Imports: 31 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/egafford/rook

Documentation ¶

Overview ¶

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 ¶

View Source

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"
)

View Source

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

View Source

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

Variables ¶

This section is empty.

Functions ¶

func GetValidVolumeSources ¶ added in v1.1.0

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,
	skipUpgradeChecks 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"`
	//LVPath is the logical Volume path for an OSD created by Ceph-volume with format '/dev/<Volume Group>/<Logical Volume>'
	LVPath string `json:"lv-path"`
}

type OrchestrationStatus ¶

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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
config Package config for OSD config managed by the operator Package config for OSD config managed by the operator Copyright 2016 The Rook Authors.	Package config for OSD config managed by the operator Package config for OSD config managed by the operator Copyright 2016 The Rook Authors.

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL