nodedaemon

Documentation

Index

• Constants
• Variables
• func Add(mgr manager.Manager, context *clusterd.Context, ...) error
• func CreateCrashCollectorSecret(context *clusterd.Context, clusterInfo *client.ClusterInfo) error
• func EnableCephExporterServiceMonitor(context *clusterd.Context, cephCluster cephv1.CephCluster, ...) error
• func MakeCephExporterMetricsService(cephCluster cephv1.CephCluster, servicePortMetricName string, ...) (*corev1.Service, error)
• type ReconcileNode
  • func (r *ReconcileNode) Reconcile(context context.Context, request reconcile.Request) (reconcile.Result, error)

Constants

const (

	// AppName is the value to the "app" label for the ceph-crash pods
	CrashCollectorAppName = "rook-ceph-crashcollector"

	// NodeNameLabel is a node name label
	NodeNameLabel = "node_name"
)

const (
	DefaultMetricsPort uint16 = 9926
)

const (
	MinVersionForCronV1 = "1.21.0"
)

Variables

var (
	MinVersionForCephExporter = cephver.CephVersion{Major: 18, Minor: 0, Extra: 0}
)

Functions

func Add

func Add(mgr manager.Manager, context *clusterd.Context, opManagerContext context.Context, opConfig opcontroller.OperatorConfig) error

Add adds a new Controller based on nodedrain.ReconcileNode and registers the relevant watches and handlers

func CreateCrashCollectorSecret

func CreateCrashCollectorSecret(context *clusterd.Context, clusterInfo *client.ClusterInfo) error

CreateCrashCollectorSecret creates the Kubernetes Crash Collector Secret

func EnableCephExporterServiceMonitor

func EnableCephExporterServiceMonitor(context *clusterd.Context, cephCluster cephv1.CephCluster, scheme *runtime.Scheme, opManagerContext context.Context, servicePortMetricName string) error

EnableCephExporterServiceMonitor add a servicemonitor that allows prometheus to scrape from the monitoring endpoint of the exporter

func MakeCephExporterMetricsService

func MakeCephExporterMetricsService(cephCluster cephv1.CephCluster, servicePortMetricName string, scheme *runtime.Scheme) (*corev1.Service, error)

MakeCephExporterMetricsService generates the Kubernetes service object for the exporter monitoring service

Types

type ReconcileNode

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

ReconcileNode reconciles ReplicaSets

func (*ReconcileNode) Reconcile

func (r *ReconcileNode) Reconcile(context context.Context, request reconcile.Request) (reconcile.Result, error)

Reconcile reconciles a node and ensures that it has necessary node-monitoring daemons. The Controller will requeue the Request to be processed again if an error is non-nil or Result.Requeue is true, otherwise upon completion it will remove the work from the queue.