Expand description
Shelly data-layer primitives.
This crate is intentionally transport-agnostic and DB-driver-agnostic. It provides:
- schema metadata
- changeset casting/validation
- repo traits + an in-memory adapter abstraction
- query composition primitives
- migration loading/state application helpers
Structs§
- Adapter
Call Contract - Adapter
Conformance Check - Adapter
Conformance Report - Analytics
Event - AppService
Error - Applied
Migration - Async
Cancellation Token - Async
Memory Repo - Async
Query Context - Auth
Credentials - Auth
Identity - Auth
Session - Axiom
Telemetry Bridge - Background
JobHandle - Background
JobRequest - Background
JobStatus - BigQuery
Driver - BigQuery
Pipeline Sink - BigQuery
Pipeline Source - Cache
Entry - Changeset
- Click
House Driver - Click
House Pipeline Sink - Click
House Pipeline Source - Compact
Rows Payload - Data
Window Request - Data
Window Response - Database
Config - Email
Message - Email
Receipt - Field
- File
Json Line Sink - File
Json Line Source - Filter
- Idempotent
InMemory Sink - InMemory
Axiom Sink - InMemory
BigQuery Adapter - InMemory
Cache Backend - InMemory
Checkpoint Store - InMemory
Click House Adapter - InMemory
Dead Letter Store - InMemory
Identity Service - InMemory
JobOrchestrator - InMemory
Object Store - InMemory
Open Search Adapter - InMemory
Pipeline Event Store - InMemory
Queue Backend - InMemory
Record Source - InMemory
Single Store Adapter - InMemory
Transactional Email Service - Incremental
Diff - Integration
Error - JobHandle
- JobOrchestrator
Background Jobs - JobRequest
- JobStatus
- Keyset
Cursor - Keyset
Pagination - Lifecycle
Hooks - Memory
Repo - Migration
- Migration
Engine - Migration
Status - MySql
Adapter - Object
Store Json Sink - Object
Store Json Source - Open
Search Adapter Driver - Open
Search Pipeline Sink - Open
Search Pipeline Source - Optimistic
Lock - Pagination
- Passthrough
Transform - Pipeline
- Pipeline
Batch - Pipeline
Conformance Check - Pipeline
Conformance Report - Pipeline
Control - Pipeline
Dead Letter - Pipeline
Dead Letter Input - Pipeline
Event - Pipeline
Operation Snapshot - Pipeline
Run - Pipeline
Runtime - Postgres
Adapter - Query
- Query
Context - Query
Observability Policy - Query
Observability Tracker - Query
Observation - Query
Window - Queue
Message - Retry
Policy - Schema
- Search
Request - Search
Response - Single
Store Driver - Single
Store Pipeline Sink - Single
Store Pipeline Source - Sink
Write Result - Sort
- SqlCommand
- Sqlite
Adapter - Stored
Row - Tenant
Background JobQuota - Tenant
Policy Context - Tenant
Policy Decision - Tenant
Quota Background Jobs - Tenant
Repo Config - Tenant
Scoped Repo - Transform
Batch - Validation
Error - Window
Page - Window
Token
Enums§
- Adapter
Kind - AppService
Error Kind - Background
JobState - Data
Error - Field
Type - Filter
Operator - Integration
Error Kind - JobState
- Keyset
Direction - Pipeline
Event Kind - Pipeline
RunCommand - Pipeline
RunStatus - Pipeline
Stage - Pipeline
Trigger - Sort
Direction - Tenant
Repo Operation - Wire
Format Profile
Constants§
- CONTEXT_
TAG_ CORRELATION_ ID - CONTEXT_
TAG_ REQUEST_ ID - CONTEXT_
TAG_ RETRY_ INITIAL_ BACKOFF_ MS - CONTEXT_
TAG_ RETRY_ MAX_ ATTEMPTS - CONTEXT_
TAG_ RETRY_ MAX_ BACKOFF_ MS - CONTEXT_
TAG_ TIMEOUT_ MS
Traits§
- Adapter
Driver - Analytics
Sink - Async
Repo - Background
JobService - BigQuery
Adapter - Cache
Backend - Checkpoint
Store - Click
House Adapter - Connection
Lifecycle - Connection
Lifecycle Hook - Dead
Letter Store - Identity
Service - JobOrchestrator
- Open
Search Adapter - Optimistic
Locking Repo - Pipeline
Event Store - Queue
Backend - Repo
- Repo
Unit OfWork - Schema
Definition - Single
Store Adapter - Sink
- Source
- Transactional
Email Service - Transform
- Trigger
DevAdapter - Typed
Query Boundary
Functions§
- adapter_
for - load_
migrations - map_
app_ service_ error - map_
app_ service_ result - map_
integration_ error - map_
integration_ result - pipeline_
records_ to_ json_ lines - query_
from_ search - run_
adapter_ conformance_ suite - run_
pipeline_ adapter_ conformance_ suite - run_
with_ contract - run_
with_ contract_ async - run_
with_ retry - run_
with_ retry_ async - write_
pipeline_ records_ to_ file