(t *testing.T, startTime time.Time, cycleDuration, slackDuration time.Duration)
| 14 | ) |
| 15 | |
| 16 | func getTenantStore(t *testing.T, startTime time.Time, cycleDuration, slackDuration time.Duration) (*tenantStore, error) { |
| 17 | var ( |
| 18 | logger = log.NewNopLogger() |
| 19 | tmpDir = t.TempDir() |
| 20 | partition = uint64(1) |
| 21 | startOffset = uint64(1) |
| 22 | blockCfg = BlockConfig{} |
| 23 | ) |
| 24 | |
| 25 | blockCfg.RegisterFlagsAndApplyDefaults("", &flag.FlagSet{}) |
| 26 | // Simulate modules.go injection of storage.trace.block config |
| 27 | blockCfg.BlockConfig.RegisterFlagsAndApplyDefaults("", &flag.FlagSet{}) |
| 28 | blockCfg.Version = encoding.DefaultEncoding().Version() |
| 29 | |
| 30 | w, err := wal.New(&wal.Config{ |
| 31 | Filepath: tmpDir, |
| 32 | IngestionSlack: 3 * time.Minute, |
| 33 | Version: encoding.DefaultEncoding().Version(), |
| 34 | }) |
| 35 | require.NoError(t, err) |
| 36 | return newTenantStore("test-tenant", partition, startOffset, startTime, cycleDuration, slackDuration, blockCfg, logger, w, encoding.DefaultEncoding(), &mockOverrides{}) |
| 37 | } |
| 38 | |
| 39 | func TestTenantStoreAdjustTimeRangeForSlack(t *testing.T) { |
| 40 | var ( |
no test coverage detected