reconciliation

Documentation

Index

• type Recorder
  • func NewRecorder(counterOpts prometheus.CounterOpts, inputName string, ...) *Recorder
  • func (r *Recorder) RecordReconcileResult(ctx context.Context, input resource.ClusterSnapshot, ...)

Types

type Recorder

type Recorder struct {
	// contains filtered or unexported fields
}

the Recorder logs and records metrics for reconciles

func NewRecorder

func NewRecorder(
	counterOpts prometheus.CounterOpts,
	inputName string,
	inputGvks []schema.GroupVersionKind,
	outputName string,
	outputGvks []schema.GroupVersionKind,
) *Recorder

NOTE: Only one Recorder should be initialized for each unique metric.

func (*Recorder) RecordReconcileResult

func (r *Recorder) RecordReconcileResult(
	ctx context.Context,
	input resource.ClusterSnapshot,
	output resource.ClusterSnapshot,
	success bool,
)

record a reconcile result