spiral-sdk 0.1.11

//! Rust clients for Spiral resources and immutable table data.
//!
//! Resource clients and wire types are generated from service contracts. Table data
//! runs through scandal and does not initialize the query engine.

mod address;
pub mod api;
mod application;
#[cfg(feature = "tables")]
mod arrow_input;
/// Credentials: bearer tokens, the providers that obtain them, and default discovery.
pub use spiral_auth as auth;
#[cfg(feature = "tables")]
mod blob;
/// Validated catalog identifiers and publication helpers.
pub mod catalog_types;
#[cfg(feature = "tables")]
mod changes;
mod client;
#[cfg(feature = "tables")]
mod column_write;
mod commit;
pub mod config;
mod connections;
#[cfg(feature = "tables")]
mod diagnostics;
#[cfg(test)]
#[cfg(feature = "tables")]
mod edit_flow_tests;
#[cfg(feature = "tables")]
mod enrichment;
mod error;
#[cfg(feature = "tables")]
mod functions;
pub mod http;
pub mod ids;
#[cfg(feature = "tables")]
mod ipc;
#[cfg(feature = "tables")]
mod local;
mod location;
#[cfg(feature = "tables")]
mod merge;
mod namespace;
#[cfg(feature = "embedded")]
mod native;
mod pagination;
mod project;
#[cfg(feature = "tables")]
mod registration;
#[cfg(feature = "tables")]
mod remote_scandal;
#[cfg(feature = "tables")]
mod scan;
/// ScanDAL contracts and wire helpers used by the SDK's execution adapters.
#[cfg(feature = "tables")]
pub mod scandal;
#[cfg(feature = "tables")]
mod scandal_backend;
#[cfg(feature = "tables")]
mod table;
#[cfg(feature = "tables")]
mod table_edit;
#[cfg(feature = "tables")]
mod table_session;
#[cfg(feature = "tables")]
mod table_write;
mod task_handle;
/// The SPQL type registry's types as Arrow extension fields.
#[cfg(feature = "tables")]
pub mod types;
#[cfg(feature = "tables")]
mod uri_resolver;
mod vector_index;
mod workload;

/// Authenticated resource facades and SDK-owned contract types.
pub mod resources {
    pub mod applications;
    pub mod arbor;
    pub mod catalog;
    pub mod connection;
    mod generated;
    pub mod location;
    pub mod organization;
    pub mod project;
    pub mod task;
    pub mod vector_index;
    pub mod workload;
    pub use crate::api::catalog as catalog_contract;
    pub use crate::api::catalog::objects as catalog_error;
    pub use crate::api::locations::objects as location_types;
    pub use crate::api::storage::objects as filesystem_types;
    pub use crate::api::tables::{objects as arbor_error, objects as arbor_types};
    pub use crate::api::tasks::objects as task_types;
    pub use crate::api::vector_indexes::objects as vector_index_types;
    pub use crate::catalog_types;
}

pub use address::{ResourceAddress, ResourceRef};
pub use application::{
    Application, ApplicationInstallation, ApplicationRegistration, Installation,
    InstallationRegistration, UserInstallation,
};
#[cfg(feature = "tables")]
pub use arrow_input::{IntoArrowStream, SortColumn, WriteInput, WriteLayout, WriteProperties};
#[cfg(feature = "tables")]
pub use blob::{Blob, BlobPack, BlobPart, BlobStat, BlobStream, BlobUpload};
#[cfg(feature = "tables")]
pub use changes::{
    CHANGE_KIND_COLUMN, ChangeImages, ChangeKind, ChangeOptions, ChangePlan, FragmentChange,
    FragmentDelta, TableCommitChanges,
};
pub use client::{Client, ClientBuilder};
#[cfg(feature = "tables")]
pub use column_write::ColumnWrite;
pub use commit::{Commit, FrozenCommit, PublishError, SavedCommit};
pub use config::{Config, ConfigBuilder};
pub use connections::NamedConnection;
#[cfg(feature = "tables")]
pub use diagnostics::ExecutionDiagnostics;
#[cfg(feature = "tables")]
pub use enrichment::{
    ENRICHMENT_VALUE_COLUMN, Enrichment, EnrichmentDefinition, enrichment_coverage, mirror_state,
    mirrored_version,
};
pub use error::Error;
#[cfg(feature = "tables")]
pub use functions::Functions;
#[cfg(feature = "tables")]
pub use local::LocalTableWrite;
pub use location::Location;
#[cfg(feature = "tables")]
pub use merge::{BySource, Matched, MergeActions, MergedRows, NotMatched};
#[cfg(feature = "embedded")]
pub use native::{NativeReadCache, NativeScandal};
pub use pagination::{List, ListStream, Page};
pub use project::{BranchHead, Project, Snapshot};
#[cfg(feature = "tables")]
pub use remote_scandal::RemoteScandal;
pub use resources::organization::Organization;
#[cfg(feature = "tables")]
pub use scan::{
    BatchStream, ColumnStatistics, FilterSupport, Scan, ScanMetrics, ScanMetricsSnapshot,
    ScanOptions, ScanRowRange, ScanSplit, ScanStatistics, ScanStream, SplitFilter, StorageCounters,
    StorageScope, TableSplit, Take, WindowCounters, WorkBatch, WorkItem, WorkStream,
};
#[cfg(feature = "tables")]
pub use scandal::plan::{PlanDecision, PlanDescription, PlanNode};
#[cfg(feature = "tables")]
pub use scandal::profile::{ExecutionOptions, ExecutionProfile, NodeProfile};
pub use spiral_contract::auth::AuthHeader;
pub use spiral_contract::call::{CallError, ServiceFailure};
#[cfg(feature = "tables")]
pub use table::{DeletedRows, Table, TableIdentity};
#[cfg(feature = "tables")]
pub use table_edit::{ColumnPath, SchemaChange, UpdatedRows};
#[cfg(feature = "tables")]
pub use table_session::TableSession;
#[cfg(feature = "tables")]
pub use table_write::{ROW_ID_COLUMN, TableWrite};
pub use task_handle::{Run, TaskHandle};
#[cfg(feature = "tables")]
pub use uri_resolver::ResourceUriResolver;
pub use vector_index::{VectorIndex, VectorIndexMetric, VectorIndexOptions};
#[cfg(feature = "tables")]
pub use vector_index::{VectorSearch, VectorSearchOptions};
pub use workload::Workload;
#[cfg(feature = "tables")]
pub use {arrow_array, arrow_ipc, arrow_schema};

/// Top-k and aggregate emits, which a scan returns in place of its rows.
#[cfg(feature = "tables")]
pub use crate::scandal::emit;
#[cfg(feature = "tables")]
pub use crate::scandal::expression::{Expression, NamedExpression, case_when, spql_call};
#[cfg(feature = "tables")]
pub use crate::scandal::functions::{
    FunctionAlias, FunctionInfo, FunctionVolatility, OverloadInfo, ParameterInfo,
};
#[cfg(feature = "tables")]
pub use crate::scandal::read_cache::{ReadCacheOptions, ReadCacheStats};
#[cfg(feature = "tables")]
pub use crate::scandal::types::PreparedWriteReceipt;
#[cfg(feature = "tables")]
pub use crate::scandal::vortex;
#[cfg(feature = "tables")]
pub use crate::scandal::{Scandal, ScandalConfig};

#[cfg(feature = "tables")]
mod storage_binding;