reporter

Documentation

Index

• func MustRegisterMetrics()
• func RecordMetrics(obj unstructured.Unstructured)
• func RequestReportUpdate(ctx context.Context, kubeClient client.Client, ...) error
• func ResetMetrics(kind string)
• type FluxStatusReporter
  • func NewFluxStatusReporter(kubeClient client.Client, instance, manager, namespace string) *FluxStatusReporter
  • func (r *FluxStatusReporter) Compute(ctx context.Context) (fluxcdv1.FluxReportSpec, error)

Functions

func MustRegisterMetrics

func MustRegisterMetrics()

MustRegisterMetrics attempts to register the metrics collectors in the controller-runtime metrics registry.

func RecordMetrics

func RecordMetrics(obj unstructured.Unstructured)

RecordMetrics records the metrics for the given object.

func RequestReportUpdate

func RequestReportUpdate(ctx context.Context, kubeClient client.Client, instance, manager, namespace string) error

RequestReportUpdate annotates the FluxReport object to trigger a reconciliation.

func ResetMetrics

func ResetMetrics(kind string)

ResetMetrics resets the metrics for the given kind.

Types

type FluxStatusReporter

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

FluxStatusReporter is responsible for computing the status report of the Flux installation.

func NewFluxStatusReporter

func NewFluxStatusReporter(kubeClient client.Client, instance, manager, namespace string) *FluxStatusReporter

NewFluxStatusReporter creates a new FluxStatusReporter for the given instance and namespace.

func (*FluxStatusReporter) Compute

func (r *FluxStatusReporter) Compute(ctx context.Context) (fluxcdv1.FluxReportSpec, error)

Compute generate the status report of the Flux installation.