Function TestIsLagged

modules/livestore/live_store_test.go:1108–1246

(t *testing.T)

}

func TestIsLagged(t *testing.T) {
	now := time.Now()
	testCases := []struct {
		name           string
		failOnHighLag  bool
		readerLag      int64
		lastRecordNano int64
		end            time.Time
		expectedLagged bool
		expectedError  bool
		description    string
	}{
		{
			name:           "config disabled - never lagged",
			failOnHighLag:  false,
			readerLag:      50000000,                             // high lag
			lastRecordNano: now.Add(-100 * time.Hour).UnixNano(), // high lag
			end:            now.Add(-1 * time.Second),
			expectedLagged: true,
			expectedError:  false,
			description:    "When FailOnHighLag is disabled, isLagged should returns true, but methods should not return error",
		},
		{
			name:           "lag unknown - should be lagged",
			failOnHighLag:  true,
			readerLag:      -1,                                   // lag unknown
			lastRecordNano: now.Add(-100 * time.Hour).UnixNano(), // high lag
			end:            now,
			expectedLagged: true,
			expectedError:  true,
			description:    "When lag is unknown (nil), prefer error over potentially incomplete results",
		},
		{
			name:           "no last record - should be lagged",
			failOnHighLag:  true,
			readerLag:      10, // low lag
			lastRecordNano: -1, // no last record yet
			end:            now,
			expectedLagged: true,
			expectedError:  true,
			description:    "When no last record yet, should not be lagged",
		},
		{
			name:           "no lag - recent request - not lagged",
			failOnHighLag:  true,
			readerLag:      100,            // low lag
			lastRecordNano: now.UnixNano(), // no lag
			end:            now.Add(-1 * time.Second),
			expectedLagged: false,
			expectedError:  false,
			description:    "When lag is low (near zero), recent requests should not be lagged",
		},
		{
			name:           "high lag - recent request - should be lagged",
			failOnHighLag:  true,
			readerLag:      5000,                                  // high lag
			lastRecordNano: now.Add(-10 * time.Second).UnixNano(), // 10 seconds ago
			end:            now.Add(-5 * time.Second),             // 5 seconds ago