testing

Documentation

Index

• type FakeReconcileStatData
• type FakeStatsReporter
  • func (r *FakeStatsReporter) GetQueueDepths() []int64
  • func (r *FakeStatsReporter) GetReconcileData() []FakeReconcileStatData
  • func (r *FakeStatsReporter) ReportQueueDepth(v int64) error
  • func (r *FakeStatsReporter) ReportReconcile(duration time.Duration, key, success string) error

Types

type FakeReconcileStatData

type FakeReconcileStatData struct {
	Duration     time.Duration
	Key, Success string
}

FakeReconcileStatData is used to record the calls to ReportReconcile

type FakeStatsReporter

type FakeStatsReporter struct {
	Lock sync.Mutex
	// contains filtered or unexported fields
}

FakeStatsReporter is a fake implementation of StatsReporter

func (*FakeStatsReporter) GetQueueDepths

func (r *FakeStatsReporter) GetQueueDepths() []int64

GetQueueDepths returns the recorded queue depth values

func (*FakeStatsReporter) GetReconcileData

func (r *FakeStatsReporter) GetReconcileData() []FakeReconcileStatData

GetReconcileData returns the recorded reconcile data

func (*FakeStatsReporter) ReportQueueDepth

func (r *FakeStatsReporter) ReportQueueDepth(v int64) error

ReportQueueDepth records the call and returns success.

func (*FakeStatsReporter) ReportReconcile

func (r *FakeStatsReporter) ReportReconcile(duration time.Duration, key, success string) error

ReportReconcile records the call and returns success.