shelly-data 0.5.0

Data-layer primitives for Shelly LiveView (schemas, changesets, repo, migrations).
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64

//! 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

mod adapter;
mod app_services;
mod async_repo;
mod changeset;
mod error;
mod integrations;
mod migration;
mod query;
mod repo;
mod schema;

pub use adapter::{AdapterKind, DatabaseConfig};
pub use app_services::{
    map_app_service_error, map_app_service_result, AppServiceError, AppServiceErrorKind,
    AppServiceResult, AuthCredentials, AuthIdentity, AuthSession, BackgroundJobHandle,
    BackgroundJobRequest, BackgroundJobService, BackgroundJobState, BackgroundJobStatus,
    CacheBackend, CacheEntry, EmailMessage, EmailReceipt, IdentityService, InMemoryCacheBackend,
    InMemoryIdentityService, InMemoryQueueBackend, InMemoryTransactionalEmailService,
    JobOrchestratorBackgroundJobs, QueueBackend, QueueMessage, TenantBackgroundJobQuota,
    TenantQuotaBackgroundJobs, TransactionalEmailService,
};
pub use async_repo::{
    AsyncCancellationToken, AsyncMemoryRepo, AsyncQueryContext, AsyncRepo, AsyncRepoFuture,
};
pub use changeset::{Changeset, ValidationError};
pub use error::{DataError, DataResult};
pub use integrations::{
    map_integration_error, map_integration_result, query_from_search,
    run_adapter_conformance_suite, run_with_contract, run_with_contract_async, run_with_retry,
    run_with_retry_async, AdapterCallContract, AdapterConformanceCheck, AdapterConformanceReport,
    AnalyticsEvent, AnalyticsSink, AxiomTelemetryBridge, BigQueryAdapter, ClickHouseAdapter,
    ConnectionLifecycle, ConnectionLifecycleHook, DataWindowRequest, DataWindowResponse,
    InMemoryAxiomSink, InMemoryBigQueryAdapter, InMemoryClickHouseAdapter, InMemoryJobOrchestrator,
    InMemoryOpenSearchAdapter, InMemorySingleStoreAdapter, IntegrationError, IntegrationErrorKind,
    IntegrationResult, JobCompletionCallback, JobHandle, JobOrchestrator, JobRequest, JobState,
    JobStatus, LifecycleHooks, OpenSearchAdapter, QueryContext, RetryPolicy, SearchRequest,
    SearchResponse, SingleStoreAdapter, SqlCommand, TriggerDevAdapter, TypedQueryBoundary,
    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,
};
pub use migration::{
    load_migrations, AppliedMigration, Migration, MigrationEngine, MigrationStatus,
};
pub use query::{
    Filter, FilterOperator, KeysetCursor, KeysetDirection, KeysetPagination, Pagination, Query,
    QueryWindow, Sort, SortDirection, WindowToken, WireFormatProfile,
};
pub use repo::{
    adapter_for, AdapterDriver, BigQueryDriver, ClickHouseDriver, CompactRowsPayload,
    IncrementalDiff, MemoryRepo, MySqlAdapter, OpenSearchAdapterDriver, PostgresAdapter, Repo, Row,
    SingleStoreDriver, SqliteAdapter, StoredRow, TenantPolicyContext, TenantPolicyDecision,
    TenantPolicyHook, TenantRepoConfig, TenantRepoOperation, TenantScopedRepo, WindowPage,
};
pub use schema::{Field, FieldType, Schema, SchemaDefinition};