reconciler

Documentation

Index

• type Reconciler
  • func NewReconciler(log log.Logger, db glsql.Querier, hc praefect.HealthChecker, ...) *Reconciler
  • func (r *Reconciler) Collect(ch chan<- prometheus.Metric)
  • func (r *Reconciler) Describe(ch chan<- *prometheus.Desc)
  • func (r *Reconciler) Run(ctx context.Context, ticker helper.Ticker) error

Types

type Reconciler

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

Reconciler implements reconciliation logic for repairing outdated repository replicas.

func NewReconciler

func NewReconciler(log log.Logger, db glsql.Querier, hc praefect.HealthChecker, storages map[string][]string, buckets []float64) *Reconciler

NewReconciler returns a new Reconciler for repairing outdated repositories.

func (*Reconciler) Collect

func (r *Reconciler) Collect(ch chan<- prometheus.Metric)

func (*Reconciler) Describe

func (r *Reconciler) Describe(ch chan<- *prometheus.Desc)

func (*Reconciler) Run

func (r *Reconciler) Run(ctx context.Context, ticker helper.Ticker) error

Run reconciles on each tick the Ticker emits. Run returns when the context is canceled, returning the error from the context.