syncvolume

Nov 12, 2021

Changes in this version

+ func RegisterMetrics()

+ type LatencyMetric interface

+ Observe func(latency time.Duration)

+ var DeleteDuration LatencyMetric = &latencyAdapter{ ... }

+ var SaveDuration LatencyMetric = &latencyAdapter{ ... }

+ var SyncDuration LatencyMetric = &latencyAdapter{ ... }

+ type Lister interface

+ ListVolumes func(context.Context) ([]storageos.Object, error)

+ type Reconciler struct

+ func NewReconciler(k8s client.Client, api Lister, apiReset chan<- struct{}, ...) *Reconciler

+ func (r *Reconciler) SetupWithManager(mgr ctrl.Manager) error

+ func (r *Reconciler) Start(ctx context.Context) error