Function runAllocator

db/sequence_allocator_test.go:877–892

(ctx context.Context, a *sequenceAllocator, frequency time.Duration)

}

func runAllocator(ctx context.Context, a *sequenceAllocator, frequency time.Duration) (allocationCount uint64) {

	allocationCount = 0
	ticker := time.NewTicker(frequency)
	for {
		select {
		case <-ticker.C:
			_, _ = a.nextSequence(ctx)
			allocationCount++
		case <-ctx.Done():
			ticker.Stop()
			log.Printf("allocator count: %v", allocationCount)
			return allocationCount
		}
	}
}

func getClientSequenceBatchSize(allocator *sequenceAllocator) uint64 {
	allocator.mutex.Lock()