Method flushNextBuffer

internal/repodiag/log_manager.go:110–112

(blobID blob.ID, buf *gather.WriteBuffer)

}

func (m *LogManager) flushNextBuffer(blobID blob.ID, buf *gather.WriteBuffer) {
	m.writer.EncryptAndWriteBlobAsync(m.ctx, blobID, buf.Bytes(), buf.Close)
}

// Sync flushes the current buffer to the repository.
func (m *LogManager) Sync() {