(b *block)
| 221 | } |
| 222 | |
| 223 | func (m *Manager) finalize(b *block) error { |
| 224 | defer m.put(b) |
| 225 | if err := b.flush(context.TODO()); err != nil { |
| 226 | return fmt.Errorf("flush: %w", err) |
| 227 | } |
| 228 | return nil |
| 229 | } |
| 230 | |
| 231 | func (m *Manager) Insert(event string) { |
| 232 | var next *block |