Skip to content

Commit 6133eb2

Browse files
committed
A-META R2 fixes: AuditSink: Debug + datafusion-plan/dispatch features
- Added Send + Sync + Debug bound on AuditSink trait so MembraneRegistry can derive Debug under --all-features - Added datafusion-plan and datafusion-dispatch feature aliases (no-op forward stubs gating audit_from_plan and parsed_query_to_plan helpers)
1 parent ffdfb02 commit 6133eb2

2 files changed

Lines changed: 8 additions & 1 deletion

File tree

crates/lance-graph-callcenter/Cargo.toml

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -44,9 +44,16 @@ auth-rls = ["auth-jwt", "query"]
4444
auth = ["auth-rls"]
4545
# LF-90 — append-only audit log skeleton (A3).
4646
audit-log = []
47+
# A-fix-audit forward-stub: enables `audit_from_plan(...)` helper that captures
48+
# rewritten DataFusion LogicalPlans into AuditEntry. No-op alias today; will
49+
# pull in `dep:datafusion` once the helper has a concrete consumer.
50+
datafusion-plan = ["query-lite"]
4751
# DM-8 — PostgREST stub uses a dependency-free hand-rolled JSON writer; the
4852
# feature flag turns the module on without dragging serde in.
4953
postgrest = []
54+
# A-fix-postgrest forward-stub: enables `parsed_query_to_plan(...)` ParsedQuery
55+
# → DataFusion LogicalPlan compiler. Wired in the follow-up dispatcher PR.
56+
datafusion-dispatch = ["query-lite"]
5057
# A4 plugin slots. Each is independently activatable; the `with_*` builder on
5158
# `MembraneRegistry` is gated on the slot feature plus the underlying module
5259
# feature (so e.g. enabling `membrane-plugins-rls` without an RLS feature is

crates/lance-graph-callcenter/src/audit.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -67,7 +67,7 @@ pub enum StatementKind {
6767

6868
/// Append-only sink. Default impl is in-memory ring buffer; production
6969
/// path swaps in a Lance-backed writer in a follow-up PR.
70-
pub trait AuditSink: Send + Sync {
70+
pub trait AuditSink: Send + Sync + std::fmt::Debug {
7171
fn append(&self, entry: AuditEntry);
7272
fn snapshot(&self) -> Vec<AuditEntry>;
7373
}

0 commit comments

Comments
 (0)