controllers

Documentation

Overview

Package controllers contains the main controller, where the reconciliation starts.

Index

• func BuildCollector(params manifests.Params) ([]client.Object, error)
• func BuildOpAMPBridge(params manifests.Params) ([]client.Object, error)
• type OpAMPBridgeReconciler
  • func NewOpAMPBridgeReconciler(params OpAMPBridgeReconcilerParams) *OpAMPBridgeReconciler
  • func (r *OpAMPBridgeReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *OpAMPBridgeReconciler) SetupWithManager(mgr ctrl.Manager) error
• type OpAMPBridgeReconcilerParams
• type OpenTelemetryCollectorReconciler
  • func NewReconciler(p Params) *OpenTelemetryCollectorReconciler
  • func (r *OpenTelemetryCollectorReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *OpenTelemetryCollectorReconciler) RunTasks(ctx context.Context, params manifests.Params) error
  • func (r *OpenTelemetryCollectorReconciler) SetupWithManager(mgr ctrl.Manager) error
• type Params
• type Task

Functions

func BuildCollector

func BuildCollector(params manifests.Params) ([]client.Object, error)

BuildCollector returns the generation and collected errors of all manifests for a given instance.

func BuildOpAMPBridge

func BuildOpAMPBridge(params manifests.Params) ([]client.Object, error)

BuildOpAMPBridge returns the generation and collected errors of all manifests for a given instance.

Types

type OpAMPBridgeReconciler

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

OpAMPBridgeReconciler reconciles a OpAMPBridge object.

func NewOpAMPBridgeReconciler

func NewOpAMPBridgeReconciler(params OpAMPBridgeReconcilerParams) *OpAMPBridgeReconciler

func (*OpAMPBridgeReconciler) Reconcile

func (r *OpAMPBridgeReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.11.2/pkg/reconcile

func (*OpAMPBridgeReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type OpAMPBridgeReconcilerParams

type OpAMPBridgeReconcilerParams struct {
	client.Client
	Recorder record.EventRecorder
	Scheme   *runtime.Scheme
	Log      logr.Logger
	Config   config.Config
}

OpAMPBridgeReconcilerParams is the set of options to build a new OpAMPBridgeReconciler.

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(ctx context.Context, 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 manifests.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
	Recorder record.EventRecorder
	Scheme   *runtime.Scheme
	Log      logr.Logger
	Tasks    []Task
	Config   config.Config
}

Params is the set of options to build a new OpenTelemetryCollectorReconciler.

type Task

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

Task represents a reconciliation task to be executed by the reconciler.