nodedaemon

Documentation

Index

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

Constants

const (
	DefaultMetricsPort uint16 = 9926
)

const (
	MinVersionForCronV1 = "1.21.0"
)

const (

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

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(cephCluster cephv1.CephCluster, scheme *runtime.Scheme, opManagerContext context.Context) 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) (*v1.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.