| 26 | } |
| 27 | |
| 28 | type writer struct { |
| 29 | logger log.Logger |
| 30 | |
| 31 | blockCfg BlockConfig |
| 32 | partition uint64 |
| 33 | startOffset uint64 |
| 34 | startTime time.Time |
| 35 | cycleDuration time.Duration |
| 36 | slackDuration time.Duration |
| 37 | |
| 38 | overrides Overrides |
| 39 | wal *wal.WAL |
| 40 | enc encoding.VersionedEncoding |
| 41 | |
| 42 | mtx sync.Mutex |
| 43 | m map[string]*tenantStore |
| 44 | } |
| 45 | |
| 46 | func newPartitionSectionWriter(logger log.Logger, partition, firstOffset uint64, startTime time.Time, cycleDuration, slackDuration time.Duration, blockCfg BlockConfig, overrides Overrides, wal *wal.WAL, enc encoding.VersionedEncoding) *writer { |
| 47 | return &writer{ |
nothing calls this directly
no outgoing calls
no test coverage detected