| 27 | ) |
| 28 | |
| 29 | type FileTransactionLogger struct { |
| 30 | events chan<- core.Event // Write-only channel for sending events |
| 31 | errors <-chan error |
| 32 | lastSequence uint64 // The last used event sequence number |
| 33 | file *os.File // The location of the transaction log |
| 34 | wg *sync.WaitGroup |
| 35 | } |
| 36 | |
| 37 | func (l *FileTransactionLogger) WritePut(key, value string) { |
| 38 | l.wg.Add(1) |
nothing calls this directly
no outgoing calls
no test coverage detected