(t *testing.T)
| 849 | } |
| 850 | |
| 851 | func TestRunCheckerWithSkip(t *testing.T) { |
| 852 | config := vultureConfiguration{ |
| 853 | tempoOrgID: "orgID", |
| 854 | tempoWriteBackoffDuration: time.Second, |
| 855 | } |
| 856 | |
| 857 | logger = zap.NewNop() |
| 858 | ticker := time.NewTicker(time.Millisecond) // fires immediately |
| 859 | defer ticker.Stop() |
| 860 | |
| 861 | // Checker function that signals completion |
| 862 | var checkerCalled bool |
| 863 | checker := func(_ *util.TraceInfo, _ *zap.Logger) { |
| 864 | checkerCalled = true |
| 865 | } |
| 866 | |
| 867 | alwaysSkip := func(_ time.Time) (newStart, ts time.Time, skip bool) { |
| 868 | return time.Now(), time.Now(), true |
| 869 | } |
| 870 | |
| 871 | runChecker(ticker, config, alwaysSkip, checker, logger) |
| 872 | time.Sleep(5 * time.Millisecond) |
| 873 | // Ensure the checker was not called due to skip=true |
| 874 | assert.False(t, checkerCalled) |
| 875 | } |
| 876 | |
| 877 | func TestRunCheckerTraceNotReady(t *testing.T) { |
| 878 | seed := time.Date(2008, 1, 1, 12, 0, 0, 0, time.UTC) |
nothing calls this directly
no test coverage detected