controllers

Documentation

Overview

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

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)
• func BuildTargetAllocator(params targetallocator.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) GetOwnedResourceTypes() []client.Object
  • func (r *OpenTelemetryCollectorReconciler) GetParams(ctx context.Context, instance v1beta1.OpenTelemetryCollector) (manifests.Params, error)
  • func (r *OpenTelemetryCollectorReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *OpenTelemetryCollectorReconciler) SetupCaches(cluster cluster.Cluster) error
  • func (r *OpenTelemetryCollectorReconciler) SetupWithManager(mgr ctrl.Manager) error
• type Params
• type TargetAllocatorReconciler
  • func NewTargetAllocatorReconciler(client client.Client, scheme *runtime.Scheme, recorder record.EventRecorder, ...) *TargetAllocatorReconciler
  • func (r *TargetAllocatorReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *TargetAllocatorReconciler) SetupWithManager(mgr ctrl.Manager) error
• type TargetAllocatorReconcilerParams

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.

func BuildTargetAllocator

func BuildTargetAllocator(params targetallocator.Params) ([]client.Object, error)

BuildTargetAllocator 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) GetOwnedResourceTypes

func (r *OpenTelemetryCollectorReconciler) GetOwnedResourceTypes() []client.Object

GetOwnedResourceTypes returns all the resource types the controller can own. Even though this method returns an array of client.Object, these are (empty) example structs rather than actual resources.

func (*OpenTelemetryCollectorReconciler) GetParams

func (r *OpenTelemetryCollectorReconciler) GetParams(ctx context.Context, instance v1beta1.OpenTelemetryCollector) (manifests.Params, error)

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

func (r *OpenTelemetryCollectorReconciler) SetupCaches(cluster cluster.Cluster) error

SetupCaches sets up caching and indexing for our controller.

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
	Config   config.Config
	Reviewer *internalRbac.Reviewer
	Version  version.Version
}

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

type TargetAllocatorReconciler

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

TargetAllocatorReconciler reconciles a TargetAllocator object.

func NewTargetAllocatorReconciler

func NewTargetAllocatorReconciler(
	client client.Client,
	scheme *runtime.Scheme,
	recorder record.EventRecorder,
	config config.Config,
	logger logr.Logger,
) *TargetAllocatorReconciler

NewTargetAllocatorReconciler creates a new reconciler for TargetAllocator objects.

func (*TargetAllocatorReconciler) Reconcile

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

Reconcile the current state of a TargetAllocator resource with the desired state.

func (*TargetAllocatorReconciler) SetupWithManager

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

SetupWithManager tells the manager what our controller is interested in.

type TargetAllocatorReconcilerParams

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

TargetAllocatorReconcilerParams is the set of options to build a new TargetAllocatorReconciler.