mgr

Documentation

Overview

Package mgr for the Ceph manager.

Package mgr for the Ceph manager.

Package mgr for the Ceph manager.

Index

• Constants
• Variables
• func CreateTempPasswordFile(password string) (*os.File, error)
• func FileBasedPasswordSupported(c *client.ClusterInfo) bool
• 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) DeployPrometheusRule(name, namespace string) error
  • func (c *Cluster) EnableServiceMonitor(activeDaemon string) error
  • func (c *Cluster) MakeMetricsService(name, activeDaemon, servicePortMetricName string) (*v1.Service, error)
  • func (c *Cluster) ReconcileMultipleServices(daemonNameToUpdate string, mgrStatSupported bool) error
  • func (c *Cluster) Start() error

Constants

const (
	AppName = "rook-ceph-mgr"

	PrometheusModuleName = "prometheus"

	PgautoscalerModuleName = "pg_autoscaler"

	// DefaultMetricsPort prometheus exporter port
	DefaultMetricsPort uint16 = 9283
)

Variables

var PrometheusExternalRuleName = "prometheus-ceph-vVERSION-rules-external"

PrometheusExternalRuleName is the name of the prometheus external rule

Functions

func CreateTempPasswordFile

func CreateTempPasswordFile(password string) (*os.File, error)

func FileBasedPasswordSupported

func FileBasedPasswordSupported(c *client.ClusterInfo) bool

FileBasedPasswordSupported check if Ceph versions have the latest Ceph dashboard command

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

func (c *Cluster) DeployPrometheusRule(name, namespace string) error

DeployPrometheusRule deploy prometheusRule that adds alerting and/or recording rules to the cluster

func (*Cluster) EnableServiceMonitor

func (c *Cluster) EnableServiceMonitor(activeDaemon string) error

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

func (*Cluster) MakeMetricsService

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

MakeMetricsService generates the Kubernetes service object for the monitoring service

func (*Cluster) ReconcileMultipleServices

func (c *Cluster) ReconcileMultipleServices(daemonNameToUpdate string, mgrStatSupported bool) error

ReconcileMultipleServices reconciles the services if the active mgr is the one running in the sidecar

func (*Cluster) Start

func (c *Cluster) Start() error

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