What's Changed
- [docs] setup buf push by @patrick-ogrady in #32
- [docs] Update README by @patrick-ogrady in #33
- [store] Add Streaming QMDB by @patrick-ogrady in #34
- [sdk-ts] Add Stream Support by @patrick-ogrady in #38
- [qmdb] Add Server by @patrick-ogrady in #39
- Add SQL Streaming by @patrick-ogrady in #42
- Add Prefix Writer/Reader by @patrick-ogrady in #45
- [ci] Fix Packages by @patrick-ogrady in #46
- [ci] Fix Publication Order by @patrick-ogrady in #47
Stats
.github/workflows/proto.yml | 33 +
.github/workflows/publish.yml | 51 +-
.github/workflows/rust.yml | 67 +
.github/workflows/scripts.yml | 19 +
.github/workflows/scripts/prepare-npm-publish.mjs | 20 +
.github/workflows/tests.yml | 115 -
.github/workflows/typescript.yml | 88 +
.gitignore | 4 +-
Cargo.lock | 84 +-
Cargo.toml | 9 +-
README.md | 2 +-
buf.yaml | 1 +
examples/sandbox/README.md | 113 +-
examples/sandbox/package-lock.json | 36 +-
examples/sandbox/package.json | 7 +-
examples/sandbox/src/App.css | 179 +-
examples/sandbox/src/App.tsx | 371 +-
examples/sandbox/src/QmdbPanel.tsx | 519 ++
examples/sandbox/src/SqlPanel.tsx | 378 ++
examples/sandbox/tsconfig.app.json | 11 +-
examples/sandbox/tsconfig.node.json | 5 +-
examples/sandbox/vite.config.ts | 12 +
examples/simulator/Cargo.toml | 2 +-
examples/simulator/src/rocks.rs | 174 +-
examples/simulator/src/server.rs | 2 +-
examples/simulator/tests/e2e_connect.rs | 226 +-
examples/simulator/tests/e2e_stream.rs | 452 ++
gen.sh | 2 +-
integration/Cargo.toml | 24 +
integration/src/lib.rs | 4 +
integration/tests/multi_instance.rs | 702 +++
proto/store/v1/common.proto | 45 +
proto/store/v1/compact.proto | 82 +-
proto/store/v1/ingest.proto | 12 +-
proto/store/v1/qmdb.proto | 134 +
proto/store/v1/query.proto | 11 +-
proto/store/v1/sql.proto | 171 +
proto/store/v1/stream.proto | 67 +
qmdb/Cargo.toml | 20 +-
qmdb/README.md | 170 +-
qmdb/src/auth.rs | 251 +-
qmdb/src/bin/qmdb.rs | 354 ++
qmdb/src/boundary.rs | 699 ++-
qmdb/src/codec.rs | 100 +-
qmdb/src/connect.rs | 899 ++++
qmdb/src/connect_client.rs | 381 ++
qmdb/src/core.rs | 254 +-
qmdb/src/error.rs | 43 +-
qmdb/src/immutable.rs | 260 +-
qmdb/src/keyless.rs | 260 +-
qmdb/src/lib.rs | 149 +-
qmdb/src/ordered.rs | 629 +--
qmdb/src/proof.rs | 483 +-
qmdb/src/prune.rs | 87 +-
qmdb/src/storage.rs | 2 +-
qmdb/src/subscription.rs | 137 +
qmdb/src/unordered.rs | 230 +-
qmdb/src/writer/core.rs | 577 +++
qmdb/src/writer/immutable.rs | 361 ++
qmdb/src/writer/keyless.rs | 507 ++
qmdb/src/writer/mod.rs | 117 +
qmdb/src/writer/ordered.rs | 408 ++
qmdb/src/writer/unordered.rs | 356 ++
qmdb/tests/common/mod.rs | 207 +-
qmdb/tests/e2e_immutable.rs | 39 +-
qmdb/tests/e2e_immutable_connect.rs | 204 +
qmdb/tests/e2e_immutable_writer.rs | 170 +
qmdb/tests/e2e_keyless.rs | 58 +-
qmdb/tests/e2e_keyless_connect.rs | 287 ++
qmdb/tests/e2e_keyless_writer.rs | 422 ++
qmdb/tests/e2e_mirror_from_local.rs | 520 ++
qmdb/tests/e2e_ordered.rs | 193 +-
qmdb/tests/e2e_ordered_connect.rs | 479 ++
qmdb/tests/e2e_ordered_prune.rs | 239 +
qmdb/tests/e2e_ordered_range_connect.rs | 491 ++
qmdb/tests/e2e_ordered_writer.rs | 257 +
qmdb/tests/e2e_unordered.rs | 36 +-
qmdb/tests/e2e_unordered_connect.rs | 210 +
qmdb/tests/e2e_unordered_writer.rs | 196 +
qmdb/ts/README.md | 12 +
qmdb/ts/package-lock.json | 72 +
qmdb/ts/package.json | 42 +
qmdb/ts/src/client.ts | 219 +
qmdb/ts/src/index.ts | 13 +
qmdb/ts/tsconfig.json | 21 +
qmdb/wasm/Cargo.toml | 22 +
qmdb/wasm/src/lib.rs | 269 +
sdk-rs/Cargo.toml | 4 +-
sdk-rs/README.md | 31 +-
sdk-rs/build.rs | 7 +
sdk-rs/src/gen/store.v1.common.rs | 1135 +++++
sdk-rs/src/gen/store.v1.compact.rs | 1319 +++--
sdk-rs/src/gen/store.v1.ingest.rs | 295 +-
sdk-rs/src/gen/store.v1.qmdb.rs | 4204 ++++++++++++++++
sdk-rs/src/gen/store.v1.query.rs | 297 +-
sdk-rs/src/gen/store.v1.sql.rs | 5496 +++++++++++++++++++++
sdk-rs/src/gen/store.v1.stream.rs | 1637 ++++++
sdk-rs/src/lib.rs | 1720 ++++++-
sdk-rs/src/match_key.rs | 56 +
sdk-rs/src/proto/mod.rs | 72 +
sdk-rs/src/proto/prune_policy_proto.rs | 108 +-
sdk-rs/src/prune_policy.rs | 353 +-
sdk-rs/src/stream_filter.rs | 183 +
sdk-ts/README.md | 23 +-
sdk-ts/__tests__/sdk.test.ts | 230 +-
sdk-ts/package-lock.json | 8 +-
sdk-ts/package.json | 9 +-
sdk-ts/src/client.ts | 48 +-
sdk-ts/src/gen/ts/buf/validate/validate_pb.ts | 377 +-
sdk-ts/src/gen/ts/store/v1/common_pb.ts | 126 +
sdk-ts/src/gen/ts/store/v1/compact_pb.ts | 173 +-
sdk-ts/src/gen/ts/store/v1/ingest_pb.ts | 38 +-
sdk-ts/src/gen/ts/store/v1/qmdb_pb.ts | 388 ++
sdk-ts/src/gen/ts/store/v1/query_pb.ts | 100 +-
sdk-ts/src/gen/ts/store/v1/sql_pb.ts | 540 ++
sdk-ts/src/gen/ts/store/v1/stream_pb.ts | 169 +
sdk-ts/src/index.ts | 94 +-
sdk-ts/src/store.ts | 1063 +++-
server/Cargo.toml | 6 +-
server/src/connect.rs | 782 ++-
server/src/engine.rs | 20 +
server/src/lib.rs | 6 +-
server/src/prune.rs | 134 +-
server/src/reduce.rs | 16 +-
server/src/stream.rs | 253 +
server/src/validate.rs | 12 +-
sql/Cargo.toml | 21 +-
sql/README.md | 12 +-
sql/benches/read_path_perf.rs | 12 +-
sql/examples/join_kv.rs | 2 +-
sql/examples/orders_kv.rs | 2 +-
sql/examples/types_kv.rs | 2 +-
sql/examples/versioned_kv.rs | 2 +-
sql/src/aggregate.rs | 6 +-
sql/src/bin/sql.rs | 150 +
sql/src/builder.rs | 2 +-
sql/src/codec.rs | 12 +-
sql/src/filter.rs | 4 +-
sql/src/lib.rs | 146 +-
sql/src/predicate.rs | 4 +-
sql/src/prune.rs | 74 +-
sql/src/scan.rs | 8 +-
sql/src/schema.rs | 12 +-
sql/src/server.rs | 707 +++
sql/src/types.rs | 4 +-
sql/src/writer.rs | 188 +-
sql/tests/common/mod.rs | 2 +-
sql/tests/e2e_slam.rs | 6 +-
sql/ts/README.md | 5 +
sql/ts/package-lock.json | 72 +
sql/ts/package.json | 41 +
sql/ts/src/client.ts | 230 +
sql/ts/src/index.ts | 12 +
sql/ts/tsconfig.json | 21 +
154 files changed, 35735 insertions(+), 4202 deletions(-)Full Changelog: v2026.4.0...v2026.4.1
Contributors
patrick-ogrady