Function assertChannelLengthWithTimeout

db/event_manager_test.go:936–954

asserts that the number of items seen in the channel within the specified time limit is the same as the expected value. WARNING: This function will drain the channel of items!

(t *testing.T, c chan interface{}, expectedLength int, timeout time.Duration)

// asserts that the number of items seen in the channel within the specified time limit is the same as the expected value.
// WARNING: This function will drain the channel of items!
func assertChannelLengthWithTimeout(t *testing.T, c chan interface{}, expectedLength int, timeout time.Duration) {
	count := 0
	for {
		if count >= expectedLength {
			// Make sure there are no additional items on the channel after a short wait.
			// This avoids relying on the longer timeout value for the final check.
			time.Sleep(timeout / 100)
			assert.Equal(t, expectedLength, count+len(c))
			return
		}

		select {
		case _ = <-c:
			count++
		case <-time.After(timeout):
			t.Fatalf("timed out waiting for items on channel... got: %d, expected: %d", count, expectedLength)
		}
	}
}

func mockDBStateChangeEvent(dbName string, state string, reason string, adminInterface string) *DBStateChangeEvent {
	body := make(Body, 5)