Function NewBatchStatsReporter

memstore/batchstats.go:32–39

NewBatchStatsReporter create a new BatchStatsReporter instance

(intervalInSeconds int, memStore MemStore, shardOwner topology.ShardOwner)

// NewBatchStatsReporter create a new BatchStatsReporter instance
func NewBatchStatsReporter(intervalInSeconds int, memStore MemStore, shardOwner topology.ShardOwner) *BatchStatsReporter {
	return &BatchStatsReporter{
		intervalInSeconds: intervalInSeconds,
		memStore:          memStore,
		shardOwner:        shardOwner,
		stopChan:          make(chan struct{}),
	}
}

// Run is a ticker function to run report periodically
func (batchStats *BatchStatsReporter) Run() {