Weny Xu 6e9a9dc333 refactor(log_store): remove associated type Namespace and Entry in LogStore (#4038) ...

* refactor(log_store): remove associated type `Namespace` in `LogStore`

* fix(test): filter entries

* refactor: ignore incomplete parts

* refactor: simplify `RawEntryReaderFilter`

* chore: avoid cloning

* test: add tests for `maybe_emit_entry`

* refactor: remove `Namespace` trait and rename `LogStoreNamespace` to `Namespace`

* chore: apply suggestions from CR

* refactor: refine `entry` method signature

* feat: ingore  any potential incomplete parts

* refactor: rename `namespace` to `provider`

* chore: add debug assertion

* refactor: associated type `Entry` in `LogStore`

* refactor: renamse `namespace` to `provider`

* refactor: remove unwrap

* refactor: let `remaining_entries` return a optional vector

* test: add basic tests for kafka logstore

* refactor: move `append` method under `cfg(test)`

* refactor: rename `RawEntry` to `Entry`

* refactor: rename `CorruptedLogEntry` to `CorruptedEntry`

* test: add tests for handling corrupted raw entry stream

* refactor: rename `ns` to `provider`

* refactor: remove `entry_stream.rs` file

* chore: remove unused code

* chore: update comments

* chore: apply suggestions from CR

* chore: update comments

* chore: apply suggestions from CR

* chore: remove Deref

* chore: add comments

* fix: ignores tail corrupted data

* chore: add comments

* fix: add `MIN_BATCH_SIZE` limit

2024-05-29 13:44:01 +00:00

..

bin

chore: deprecate nyc-taxi benchmark (#3891)

2024-05-09 08:59:38 +00:00

lib.rs

feat: introduce wal benchmarker (#3446)

2024-04-03 03:16:05 +00:00

metrics.rs

feat: introduce wal benchmarker (#3446)

2024-04-03 03:16:05 +00:00

wal_bench.rs

refactor(log_store): remove associated type Namespace and Entry in LogStore (#4038)

2024-05-29 13:44:01 +00:00