mgr

Documentation

Overview

Package mgr for the Ceph manager.

Package mgr for the Ceph manager.

Package mgr for the Ceph manager.

Index

• Constants
• func GeneratePassword(length int) (string, error)
• func GenerateRandomBytes(length int) ([]byte, error)
• func IsModuleInSpec(modules []cephv1.Module, moduleName string) bool
• type Cluster
  • func New(context *clusterd.Context, clusterInfo *cephclient.ClusterInfo, ...) *Cluster
  • func (c *Cluster) EnableServiceMonitor() error
  • func (c *Cluster) GetActiveMgr() (string, error)
  • func (c *Cluster) MakeMetricsService(name, servicePortMetricName string) (*v1.Service, error)
  • func (c *Cluster) SetMgrRoleLabel(daemonNameToUpdate string, isActive bool) error
  • func (c *Cluster) Start() error

Constants

const (
	AppName = "rook-ceph-mgr"

	PrometheusModuleName = "prometheus"

	// DefaultMetricsPort prometheus exporter port
	DefaultMetricsPort uint16 = 9283
)

Functions

func GeneratePassword

func GeneratePassword(length int) (string, error)

func GenerateRandomBytes

func GenerateRandomBytes(length int) ([]byte, error)

GenerateRandomBytes returns securely generated random bytes.

func IsModuleInSpec

func IsModuleInSpec(modules []cephv1.Module, moduleName string) bool

IsModuleInSpec returns whether a module is present in the CephCluster manager spec

Types

type Cluster

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

Cluster represents the Rook and environment configuration settings needed to set up Ceph mgrs.

func New

func New(context *clusterd.Context, clusterInfo *cephclient.ClusterInfo, spec cephv1.ClusterSpec, rookVersion string) *Cluster

New creates an instance of the mgr

func (*Cluster) EnableServiceMonitor

func (c *Cluster) EnableServiceMonitor() error

EnableServiceMonitor add a servicemonitor that allows prometheus to scrape from the monitoring endpoint of the cluster

func (*Cluster) GetActiveMgr

func (c *Cluster) GetActiveMgr() (string, error)

func (*Cluster) MakeMetricsService

func (c *Cluster) MakeMetricsService(name, servicePortMetricName string) (*v1.Service, error)

MakeMetricsService generates the Kubernetes service object for the monitoring service

func (*Cluster) SetMgrRoleLabel

func (c *Cluster) SetMgrRoleLabel(daemonNameToUpdate string, isActive bool) error

SetMgrRoleLabel sets 'mgr_role: active' label to given manager daemon pods if isActive is true. Otherwise sets 'mgr_role: standby' label to manager pods.

func (*Cluster) Start

func (c *Cluster) Start() error

Start begins the process of running a cluster of Ceph mgrs.