Contract version: v0.72.0
Roadmap row fingerprint: sha256:8cec8738b10f5d31e217a027898570b15e26176abfcb0e0ef67b4e043c7110f8
RockStream ingests changing data, continuously maintains a documented SQL subset as durable materialized views, and serves globally committed results to PostgreSQL-compatible clients while surviving ordinary distributed-system failures without losing or silently corrupting committed state.
The matrix is generated from capabilities.toml. Core records are release-gated; Maintain records remain supported without being a growth area; Experimental records have no continuity guarantee.
| ID | Class | Capability | Tier | Reachability | Dispatch evidence | Proof | Documentation |
|---|---|---|---|---|---|---|---|
connector.kafka-source |
connector | Kafka source | Core | Connector runtime | kafka_source_runtime |
crates/rockstream-connectors/tests/kafka_source_guarantee_matrix_tests.rs::kafka_source_mid_epoch_rebalance_recovers_exact_transcript |
docs/connectors.md#kafka-source |
connector.postgres-cdc |
connector | PostgreSQL CDC source | Core | Connector runtime | postgres_cdc_runtime |
crates/rockstream-connectors/tests/postgres_cdc_guarantee_matrix_tests.rs::postgres_cdc_snapshot_stream_fence_has_exact_transcript |
docs/connectors.md#postgresql-cdc |
language.aggregates.exact |
language | Exact integer and decimal aggregation | Core | SQL over pgwire | query_async_entry, sql_lowering, plan_compilation |
crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_aggregate_exact_int_sum |
docs/language-features.md#implemented-today |
language.aggregates.float |
language | Approximate floating-point aggregation | Experimental | SQL over pgwire | query_async_entry, sql_lowering, plan_compilation |
crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_aggregate_float_sum |
docs/language-features.md#implemented-today |
language.aggregates.text |
language | Text aggregation (MIN, MAX) | Maintain | SQL over pgwire | query_async_entry, sql_lowering, plan_compilation |
crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_aggregate_text_min_max |
docs/language-features.md#implemented-today |
language.broader-production-sql |
language | Broader production SQL surface | Experimental | Roadmap contract only | — | — | docs/language-features.md#documented-planned-surface |
language.connector-expansion |
language | Connector expansion | Experimental | Not SQL-reachable | — | — | docs/language-features.md#documented-planned-surface |
language.connector-schema-contracts |
language | Connector schema contracts | Maintain | Rust connector API | — | — | docs/language-features.md#documented-planned-surface |
language.custom-algebra |
language | Custom merge laws and user-visible CRDT columns | Experimental | Not SQL-reachable | — | — | docs/language-features.md#documented-planned-surface |
language.ddl-coordination |
language | DDL coordination | Experimental | Not SQL-reachable | — | — | docs/language-features.md#documented-planned-surface |
language.dead-letter-queue |
language | Dead-letter queue operations | Experimental | Not SQL-reachable | — | — | docs/language-features.md#documented-planned-surface |
language.dml |
language | DML | Core | SQL over pgwire | query_async_entry, sql_lowering, plan_compilation, response_encoding |
crates/rockstream-gateway/tests/gateway_dml_tests.rs::test_update_accumulates_in_write_buffer |
docs/language-features.md#implemented-today |
language.explain-index |
language | Standalone EXPLAIN INDEX | Experimental | Not SQL-reachable | — | — | docs/language-features.md#current-frontend-gaps |
language.historical-streaming-reads |
language | Historical and streaming reads | Core | SUBSCRIBE over pgwire | query_async_entry, response_encoding |
crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_subscribe_pgwire_dispatch |
docs/language-features.md#implemented-today |
language.hop-session-windows |
language | HOP and SESSION windows | Experimental | Not SQL-reachable | — | — | docs/language-features.md#documented-planned-surface |
language.indexes |
language | Secondary indexes | Maintain | SQL over pgwire | query_async_entry, sql_lowering, plan_compilation, response_encoding |
— | docs/language-features.md#implemented-today |
language.joins.cross |
language | Cartesian cross-joins | Experimental | SQL over pgwire | query_async_entry, sql_lowering, plan_compilation |
crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_join_cross |
docs/language-features.md#implemented-today |
language.joins.equi-integer |
language | Exact integer key equi-joins | Core | SQL over pgwire | query_async_entry, sql_lowering, plan_compilation |
crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_join_equi_integer |
docs/language-features.md#implemented-today |
language.joins.equi-text |
language | Binary UTF-8 text key equi-joins | Maintain | SQL over pgwire | query_async_entry, sql_lowering, plan_compilation |
crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_join_equi_text |
docs/language-features.md#implemented-today |
language.joins.float |
language | Floating-point key joins | Experimental | SQL over pgwire | query_async_entry, sql_lowering |
crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_join_inner_f64 |
docs/language-features.md#implemented-today |
language.lateral |
language | LATERAL subqueries and functions | Experimental | Not SQL-reachable | — | — | docs/language-features.md#documented-planned-surface |
language.lifecycle-visibility |
language | View and backfill lifecycle visibility | Experimental | Not SQL-reachable | — | — | docs/language-features.md#documented-planned-surface |
language.limit-order-by |
language | LIMIT and ORDER BY | Experimental | Frontend rejects the construct | — | — | docs/language-features.md#current-frontend-gaps |
language.multitenancy-quotas |
language | Multi-tenancy and quotas | Maintain | SQL over pgwire | query_sync_entry, catalog_query, response_encoding |
— | docs/language-features.md#implemented-today |
language.optimistic-transactions |
language | Optimistic transactions | Experimental | Not SQL-reachable | — | — | docs/language-features.md#documented-planned-surface |
language.optimizer-hints |
language | Optimizer hint comments | Experimental | Not SQL-reachable | — | — | docs/language-features.md#documented-planned-surface |
language.query-diagnostics |
language | Query diagnostics | Maintain | SQL over pgwire | query_async_entry, sql_lowering, response_encoding |
— | docs/language-features.md#implemented-today |
language.query-read |
language | Query and read surface | Core | SQL over pgwire | query_async_entry, sql_lowering, response_encoding |
crates/rockstream-gateway/tests/gateway_dml_tests.rs::test_create_view_and_select |
docs/language-features.md#implemented-today |
language.recursive-cte |
language | Recursive CTEs | Experimental | Not SQL-reachable | — | — | docs/language-features.md#documented-planned-surface |
language.removed-connectors |
language | Removed connector rejection | Maintain | SQL over pgwire | query_async_entry, response_encoding |
— | docs/language-features.md#implemented-today |
language.resource-visibility |
language | Resource visibility | Maintain | SQL over pgwire | query_sync_entry, catalog_query, response_encoding |
— | docs/language-features.md#implemented-today |
language.scalar-expressions |
language | Scalar expressions | Core | SQL over pgwire | query_async_entry, sql_lowering |
crates/rockstream-sql/tests/tpch_plans.rs::tpch_q6_filter_aggregate_no_join |
docs/language-features.md#implemented-today |
language.schema-evolution-introspection |
language | Schema evolution introspection | Experimental | Not SQL-reachable | — | — | docs/language-features.md#documented-planned-surface |
language.secret-ddl |
language | Secret DDL and schema defaults | Maintain | Secret DDL over pgwire | query_async_entry, query_sync_entry, response_encoding |
— | docs/language-features.md#documented-planned-surface |
language.session-freshness |
language | Session and freshness controls | Core | SQL over pgwire | query_async_entry, query_sync_entry, response_encoding |
crates/rockstream-gateway/tests/gateway_proof_tests.rs::write_fence_token_can_be_used_by_another_session_via_after_fence |
docs/language-features.md#implemented-today |
language.source-lifecycle |
language | Source lifecycle DDL | Experimental | Not SQL-reachable | — | — | docs/language-features.md#documented-planned-surface |
language.system-catalog |
language | System catalog SQL | Maintain | SQL over pgwire | query_sync_entry, catalog_query, response_encoding |
— | docs/language-features.md#implemented-today |
language.transaction-semantics |
language | Transaction semantics | Core | SQL over pgwire | query_async_entry, query_sync_entry, response_encoding |
crates/rockstream-gateway/tests/gateway_proof_tests.rs::explicit_idempotency_key_dedupes_multi_statement_transaction_replay |
docs/language-features.md#implemented-today |
language.uncommon-expressions |
language | Uncommon expressions and operators | Experimental | Frontend partial coverage | — | — | docs/language-features.md#current-frontend-gaps |
language.view-on-view-dag |
language | View-on-view DAGs | Core | SQL over pgwire | query_async_entry, sql_lowering, view_dispatch, plan_compilation |
crates/rockstream-sql/tests/lfs_catalog.rs::test_5_level_view_chain_convergence |
docs/language-features.md#implemented-today |
language.view-replacement |
language | View replacement workflow | Experimental | Not SQL-reachable | — | — | docs/language-features.md#documented-planned-surface |
language.view-retention |
language | View retention and historical knobs | Experimental | Not SQL-reachable | — | — | docs/language-features.md#documented-planned-surface |
language.views |
language | Views | Core | SQL over pgwire | query_async_entry, sql_lowering, view_dispatch, plan_compilation, response_encoding |
crates/rockstream-gateway/tests/gateway_dml_tests.rs::test_refresh_materialized_view_roundtrip |
docs/language-features.md#implemented-today |
language.window.ranking |
language | Ranking functions (ROW_NUMBER, RANK, DENSE_RANK, LAG, LEAD) | Maintain | SQL over pgwire | query_async_entry, sql_lowering, plan_compilation |
crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_window_ranking |
docs/language-features.md#implemented-today |
language.window.slide |
language | Sliding hopping time windows | Core | SQL over pgwire | query_async_entry, sql_lowering, plan_compilation |
crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_window_sliding |
docs/language-features.md#implemented-today |
language.window.tumble |
language | Fixed tumbling time windows | Core | SQL over pgwire | query_async_entry, sql_lowering, plan_compilation |
crates/rockstream-gateway/tests/live_exec_tumble_window_durability_lfs_tests.rs::compiled_tumble_window_state_persists_across_restart_lfs |
docs/language-features.md#implemented-today |
language.write-classification |
language | Write classification | Experimental | Not SQL-reachable | — | — | docs/language-features.md#documented-planned-surface |
sink.kafka |
sink | Kafka sink | Experimental | Connector runtime | kafka_sink_runtime, kafka_view_sink_runtime |
— | docs/connectors.md#kafka-sink |
This inventory is derived from dispatch evidence referenced by Core records; it is not a second hand-written operator list.
| Identity | Source | Anchor | Surface |
|---|---|---|---|
kafka_source_runtime |
crates/rockstream-connectors/src/lib.rs |
KafkaSource |
Kafka source |
plan_compilation |
crates/rockstream-ops/src/compile.rs |
compile_node |
operator compilation |
postgres_cdc_runtime |
crates/rockstream-connectors/src/postgres_cdc.rs |
PostgresCdcSource |
PostgreSQL CDC source |
query_async_entry |
crates/rockstream-gateway/src/server.rs |
dispatch_async_with_conn |
pgwire query entry |
query_sync_entry |
crates/rockstream-gateway/src/server.rs |
dispatch_sync |
synchronous/catalog dispatch |
response_encoding |
crates/rockstream-gateway/src/server.rs |
DataRowEncoder |
PostgreSQL response encoding |
sql_lowering |
crates/rockstream-sql/src/frontend.rs |
sql_to_plan_node |
DataFusion parse and PlanNode lowering |
view_dispatch |
crates/rockstream-gateway/src/server.rs |
handle_create_view |
materialized-view dispatch |
This block is generated from the five-behavior ledger in capabilities.toml.
| Capability | Behavior | Statement | Proof | Paired proof | Bound | Metric | Bound outcome |
|---|---|---|---|---|---|---|---|
connector.kafka-source |
incremental |
A Kafka record is polled and emitted as an exact incremental delta batch. | crates/rockstream-connectors/tests/kafka_source_guarantee_matrix_tests.rs::kafka_source_incremental_stream_has_exact_transcript |
— | — | — | — |
connector.kafka-source |
backfill |
A Kafka source starting at earliest offset backfills all partition records before subsequent poll deltas. | crates/rockstream-connectors/tests/kafka_source_guarantee_matrix_tests.rs::kafka_source_earliest_backfill_all_records |
— | — | — | — |
connector.kafka-source |
checkpoint_recovery |
A recovered source resumes at the committed offset and observes exactly the records produced after it in both local and object-store backends. | crates/rockstream-connectors/tests/kafka_source_guarantee_matrix_tests.rs::kafka_source_committed_offset_recovery_has_exact_transcript |
crates/rockstream-connectors/tests/source_durability_minio_tests.rs::retained_source_checkpoint_recovery_has_exact_cdc_and_kafka_transcript_minio |
— | — | — |
connector.kafka-source |
state_growth |
Kafka source buffer is bounded by the configured credit limit and exposes its fill metric. | crates/rockstream-connectors/tests/dlq_backpressure_threshold_tests.rs::kafka_source_queue_bounded_with_fill_metric |
— | configured poll credit limit | kafka_source_poll_fill_level | poll applies backpressure or returns its RS-coded resource error |
connector.kafka-source |
failure |
An unreachable broker or invalid configuration fails closed with an actionable RS-coded error. | crates/rockstream-connectors/tests/kafka_source_non_broker_tests.rs::kafka_source_unreachable_broker_fails_closed |
— | — | — | — |
connector.postgres-cdc |
incremental |
A PostgreSQL logical replication delta is captured and emitted as an exact incremental record batch. | crates/rockstream-connectors/tests/postgres_cdc_guarantee_matrix_tests.rs::postgres_cdc_snapshot_stream_fence_has_exact_transcript |
— | — | — | — |
connector.postgres-cdc |
backfill |
Initial snapshot backfills every committed row from the source PostgreSQL table before streaming live deltas. | crates/rockstream-connectors/tests/postgres_cdc_guarantee_matrix_tests.rs::postgres_cdc_initial_snapshot_backfills_all_rows |
— | — | — | — |
connector.postgres-cdc |
checkpoint_recovery |
Each committed replication-slot LSN boundary recovers exactly the changes committed after it in both local and object-store backends. | crates/rockstream-connectors/tests/postgres_cdc_guarantee_matrix_tests.rs::postgres_cdc_each_commit_boundary_recovers_exactly_once |
crates/rockstream-connectors/tests/cdc_transaction_durability_minio_tests.rs::shared_slot_checkpoint_reopens_once_minio |
— | — | — |
connector.postgres-cdc |
state_growth |
PostgreSQL CDC queue is bounded by the configured in-flight limit and exposes its fill metric. | crates/rockstream-connectors/tests/dlq_backpressure_threshold_tests.rs::postgres_cdc_queue_bounded_with_fill_metric |
— | configured in-flight record queue | postgres_cdc_queue_fill_ratio | the source applies backpressure or rejects with its RS-coded resource error |
connector.postgres-cdc |
failure |
An invalid or lost replication slot fails closed with an actionable RS-coded error. | crates/rockstream-connectors/tests/postgres_cdc_guarantee_matrix_tests.rs::postgres_cdc_invalid_slot_fails_closed |
— | — | — | — |
language.aggregates.exact |
incremental |
Exact aggregation deltas update the grouped sum and count transcripts incrementally. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_aggregate_exact_incremental |
— | — | — | — |
language.aggregates.exact |
backfill |
Aggregate backfill evaluates the complete snapshot over exact numeric groups before deltas. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_aggregate_exact_backfill |
— | — | — | — |
language.aggregates.exact |
checkpoint_recovery |
A reopened aggregate shard restores the committed exact grouped results. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_aggregate_exact_checkpoint_recovery |
— | — | — | — |
language.aggregates.exact |
state_growth |
Exact aggregate arrangements use the configured state budget and expose fill level. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_aggregate_exact_state_growth |
— | configured aggregate state budget | aggregate_state_fill_ratio | the write is rejected with its RS-coded resource error |
language.aggregates.exact |
failure |
Invalid aggregate expressions fail closed with an actionable RS-coded error. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_aggregate_exact_failure |
— | — | — | — |
language.dml |
incremental |
INSERT, UPDATE, and DELETE deltas change the materialized result exactly once. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_dml_incremental |
— | — | — | — |
language.dml |
backfill |
DML backfill starts from the committed table snapshot before applying mutations. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_dml_backfill |
— | — | — | — |
language.dml |
checkpoint_recovery |
Reopening the durable shard restores all committed DML effects. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_dml_checkpoint_recovery |
— | — | — | — |
language.dml |
state_growth |
The write buffer is bounded, exposes fill level, and cannot accumulate indefinitely. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_dml_state_growth |
— | configured write-buffer budget | write_buffer_fill_ratio | the write is rejected with its RS-coded resource error |
language.dml |
failure |
Invalid DML returns an actionable RS-coded error and preserves the prior committed result. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_dml_failure |
— | — | — | — |
language.historical-streaming-reads |
incremental |
SUBSCRIBE emits the snapshot followed by each committed delta in order. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_subscribe_incremental |
crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_subscribe_pgwire_dispatch |
— | — | — |
language.historical-streaming-reads |
backfill |
A historical subscription starts from the requested committed snapshot before streaming deltas. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_subscribe_backfill |
— | — | — | — |
language.historical-streaming-reads |
checkpoint_recovery |
Reconnecting a subscription resumes from durable committed state without duplicate rows. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_subscribe_checkpoint_recovery |
— | — | — | — |
language.historical-streaming-reads |
state_growth |
Subscription output uses a bounded delivery window and reports fill level. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_subscribe_state_growth |
— | configured subscription delivery window | subscription_buffer_fill_ratio | delivery applies backpressure or returns its RS-coded resource error |
language.historical-streaming-reads |
failure |
An invalid subscription target returns an actionable RS-coded error. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_subscribe_failure |
— | — | — | — |
language.joins.equi-integer |
incremental |
Integer equi-join deltas update the relational result without changing unaffected rows. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_join_equi_integer_incremental |
— | — | — | — |
language.joins.equi-integer |
backfill |
Join backfill builds the complete snapshot result before later input deltas. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_join_equi_integer_backfill |
— | — | — | — |
language.joins.equi-integer |
checkpoint_recovery |
A reopened join shard restores the committed relational transcript in both local and object-store backends. | crates/rockstream-gateway/tests/live_exec_join_durability_lfs_tests.rs::compiled_join_state_persists_across_restart_lfs |
crates/rockstream-gateway/tests/core_operator_durability_minio_tests.rs::compiled_join_state_persists_across_restart_minio |
— | — | — |
language.joins.equi-integer |
state_growth |
Join arrangements use the configured state budget and expose fill level. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_join_equi_integer_state_growth |
— | configured arrangement state budget | arrangement_state_fill_ratio | the write is rejected with its RS-coded resource error |
language.joins.equi-integer |
failure |
Invalid join input returns an actionable RS-coded error. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_join_equi_integer_failure |
— | — | — | — |
language.query-read |
incremental |
A committed row delta is reflected in the same SELECT transcript as the corresponding source change. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_query_read_incremental |
— | — | — | — |
language.query-read |
backfill |
A snapshot read returns every committed source row before subsequent deltas are observed. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_query_read_backfill |
— | — | — | — |
language.query-read |
checkpoint_recovery |
Reopening the local durable shard restores the committed read transcript. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_query_read_checkpoint_recovery |
— | — | — | — |
language.query-read |
state_growth |
Read results are materialized per query and do not retain an unbounded process buffer. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_query_read_state_growth |
— | one query result set | query_result_rows | the query fails with its RS-coded resource error |
language.query-read |
failure |
Invalid read input returns an actionable RS-coded error instead of an empty success. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_query_read_failure |
— | — | — | — |
language.scalar-expressions |
incremental |
Scalar expressions are recomputed for each changed input row and preserve the exact projected transcript. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_scalar_incremental |
— | — | — | — |
language.scalar-expressions |
backfill |
Backfill evaluates the scalar expression over the complete snapshot before deltas. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_scalar_backfill |
— | — | — | — |
language.scalar-expressions |
checkpoint_recovery |
A reopened shard preserves the scalar result of committed rows. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_scalar_checkpoint_recovery |
— | — | — | — |
language.scalar-expressions |
state_growth |
Scalar evaluation retains no input-sized queue between queries. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_scalar_state_growth |
— | one query result set | query_result_rows | the query fails with its RS-coded resource error |
language.scalar-expressions |
failure |
Unsupported scalar input returns an actionable RS-coded error. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_scalar_failure |
— | — | — | — |
language.session-freshness |
incremental |
Freshness controls make committed writes visible according to the session fence. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_freshness_incremental |
— | — | — | — |
language.session-freshness |
backfill |
A session fence observes the complete committed snapshot at the requested frontier. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_freshness_backfill |
— | — | — | — |
language.session-freshness |
checkpoint_recovery |
Freshness tokens remain valid after reopening the durable session state. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_freshness_checkpoint_recovery |
— | — | — | — |
language.session-freshness |
state_growth |
Session freshness retains only bounded fence metadata and reports its fill level. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_freshness_state_growth |
— | configured fence-token budget | fence_token_fill_ratio | new fence creation returns its RS-coded resource error |
language.session-freshness |
failure |
An invalid freshness setting returns an actionable RS-coded error. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_freshness_failure |
— | — | — | — |
language.transaction-semantics |
incremental |
A committed transaction applies its complete statement set atomically to the result transcript. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_transaction_incremental |
— | — | — | — |
language.transaction-semantics |
backfill |
Transaction backfill observes only the committed snapshot and excludes uncommitted statements. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_transaction_backfill |
— | — | — | — |
language.transaction-semantics |
checkpoint_recovery |
A committed transaction remains durable and replay-safe after restart. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_transaction_checkpoint_recovery |
— | — | — | — |
language.transaction-semantics |
state_growth |
Transaction statements are bounded by the configured write-buffer budget and expose fill level. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_transaction_state_growth |
— | configured transaction write-buffer budget | transaction_buffer_fill_ratio | the transaction is rejected with its RS-coded resource error |
language.transaction-semantics |
failure |
A failed or replayed transaction returns an actionable RS-coded error or exact no-op. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_transaction_failure |
— | — | — | — |
language.view-on-view-dag |
incremental |
View-on-view deltas propagate through the dependency DAG once and preserve the downstream transcript. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_view_dag_incremental |
— | — | — | — |
language.view-on-view-dag |
backfill |
DAG backfill materializes dependencies in topological order before downstream deltas. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_view_dag_backfill |
— | — | — | — |
language.view-on-view-dag |
checkpoint_recovery |
A reopened DAG restores committed upstream and downstream view state. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_view_dag_checkpoint_recovery |
— | — | — | — |
language.view-on-view-dag |
state_growth |
DAG compilation and dependency state are bounded by the configured view budget. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_view_dag_state_growth |
— | configured view dependency budget | view_dependency_fill_ratio | the view operation is rejected with its RS-coded resource error |
language.view-on-view-dag |
failure |
A cycle or invalid dependency returns an actionable RS-coded error. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_view_dag_failure |
— | — | — | — |
language.views |
incremental |
View maintenance publishes each source delta to the materialized view transcript. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_views_incremental |
— | — | — | — |
language.views |
backfill |
View creation backfills from the committed source snapshot before later deltas. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_views_backfill |
— | — | — | — |
language.views |
checkpoint_recovery |
A reopened materialized view restores its committed output. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_views_checkpoint_recovery |
— | — | — | — |
language.views |
state_growth |
View maintenance is bounded by the configured arrangement budget and exposes fill level. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_views_state_growth |
— | configured view arrangement budget | view_state_fill_ratio | the write is rejected with its RS-coded resource error |
language.views |
failure |
Invalid view definitions return an actionable RS-coded error and do not publish partial state. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_views_failure |
— | — | — | — |
language.window.slide |
incremental |
Sliding window deltas recompute overlapping slice bounds and preserve exact ordered outputs. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_window_slide_incremental |
— | — | — | — |
language.window.slide |
backfill |
Sliding window backfill evaluates all historical slice intervals across the snapshot. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_window_slide_backfill |
— | — | — | — |
language.window.slide |
checkpoint_recovery |
A reopened sliding window shard restores committed slice state. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_window_slide_checkpoint_recovery |
— | — | — | — |
language.window.slide |
state_growth |
Sliding window buffers retain only unexpired active slices and report fill level. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_window_slide_state_growth |
— | configured slide window slice budget | window_state_fill_ratio | the write is rejected with its RS-coded resource error |
language.window.slide |
failure |
Unsupported sliding window specifications fail closed with an actionable RS-coded error. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_window_slide_failure |
— | — | — | — |
language.window.tumble |
incremental |
Tumbling window deltas assign rows into non-overlapping epoch buckets deterministically. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_window_tumble_incremental |
— | — | — | — |
language.window.tumble |
backfill |
Tumble window backfill processes the complete snapshot before subsequent stream deltas. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_window_tumble_backfill |
— | — | — | — |
language.window.tumble |
checkpoint_recovery |
A reopened tumble window shard restores the committed window transcript in both local and object-store backends. | crates/rockstream-gateway/tests/live_exec_tumble_window_durability_lfs_tests.rs::compiled_tumble_window_state_persists_across_restart_lfs |
crates/rockstream-gateway/tests/core_operator_durability_minio_tests.rs::compiled_tumble_window_state_persists_across_restart_minio |
— | — | — |
language.window.tumble |
state_growth |
Tumble window state is bounded by the active watermark retention window and reports fill level. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_window_tumble_state_growth |
— | configured tumble window partition budget | window_state_fill_ratio | the write is rejected with its RS-coded resource error |
language.window.tumble |
failure |
Invalid window parameters fail closed with an actionable RS-coded error. | crates/rockstream-gateway/tests/core_operator_semantics_e2e_tests.rs::core_window_tumble_failure |
— | — | — | — |