controllers

Documentation

Index

• type OpenTelemetryCollectorReconciler
  • func NewReconciler(p Params) *OpenTelemetryCollectorReconciler
  • func (r *OpenTelemetryCollectorReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)
  • func (r *OpenTelemetryCollectorReconciler) RunTasks(ctx context.Context, params reconcile.Params) error
  • func (r *OpenTelemetryCollectorReconciler) SetupWithManager(mgr ctrl.Manager) error
• type Params
• type Task

Types

type OpenTelemetryCollectorReconciler

type OpenTelemetryCollectorReconciler struct {
	client.Client
	// contains filtered or unexported fields
}

OpenTelemetryCollectorReconciler reconciles a OpenTelemetryCollector object

func NewReconciler

func NewReconciler(p Params) *OpenTelemetryCollectorReconciler

NewReconciler creates a new reconciler for OpenTelemetryCollector objects

func (*OpenTelemetryCollectorReconciler) Reconcile

func (r *OpenTelemetryCollectorReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)

Reconcile the current state of an OpenTelemetry collector resource with the desired state

func (*OpenTelemetryCollectorReconciler) RunTasks

func (r *OpenTelemetryCollectorReconciler) RunTasks(ctx context.Context, params reconcile.Params) error

RunTasks runs all the tasks associated with this reconciler

func (*OpenTelemetryCollectorReconciler) SetupWithManager

func (r *OpenTelemetryCollectorReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager tells the manager what our controller is interested in

type Params

type Params struct {
	client.Client
	Log    logr.Logger
	Scheme *runtime.Scheme
	Config config.Config
	Tasks  []Task
}

Params is the set of options to build a new openTelemetryCollectorReconciler

type Task

type Task struct {
	Name        string
	Do          func(context.Context, reconcile.Params) error
	BailOnError bool
}

Task represents a reconciliation task to be executed by the reconciler