Crate digdigdig3_station 

digdigdig3-station — Layer 2 of the digdigdig3 workspace.

High-level consumer-facing builder over digdigdig3::connector_manager::ExchangeHub. See docs/plans/station-architecture.md for design, docs/plans/station-phase-1-plan.md for the phase-by-phase implementation roadmap.

Phase 1 scope (current): skeleton only. Modules below are stubs.

Re-exports

pub use backfill::fetch_history;

pub use bar_align::bar_align_points;

pub use bar_align::load_bar_aligned;

pub use bar_align::load_for_key;

pub use bar_align::BarAlignedSeries;

pub use bar_align::FillPolicy;

pub use bar_align::ScalarBar;

pub use normalize::active_only;

pub use normalize::canonical_status;

pub use normalize::is_active;

pub use normalize::SymbolStatus;

pub use ws_health::WsHealth;

pub use builder::StationBuilder;

pub use cache::ticker_cache;

pub use cache::CacheConfig;

pub use cache::TickerKey;

pub use error::Result;

pub use error::StationError;

pub use persistence::PersistenceConfig;

pub use series::DataPoint;

pub use series::Kind;

pub use series::Series;

pub use series::SeriesKey;

pub use series::SharedSeries;

pub use series::SharedSeriesMap;

pub use quota::ConsumerHandle;

pub use quota::ConsumerQuota;

pub use quota::ConsumerWhitelist;

pub use quota::QuotaError;

pub use station::Station;

pub use subscription::Event;

pub use subscription::FailedStream;

pub use subscription::Stream;

pub use subscription::SubscribeReport;

pub use subscription::SubscriptionHandle;

pub use subscription::SubscriptionSet;

pub use subscription::WarmupReport;

pub use series::DiskStore;

pub use series::PollSpec;

pub use gap_heal::GapHealConfig;

pub use storage::StorageConfig;

pub use storage::StorageManager;

pub use storage::StreamKey;

pub use storage::EventLog;

pub use storage::EventLogIter;

pub use storage::EventRecord;

pub use replay::ReplayHub;

pub use replay::ReplayConfig;

pub use replay::ReplayRate;

pub use orderbook::OrderBookTracker;

pub use orderbook::OrderBookError;

pub use rest_cache::RestCache;

pub use settings::SettingsError;

pub use settings::SettingsStore;

pub use cure::IntegrityChecker;

pub use cure::IntegrityReport;

pub use cure::Deduper;

pub use cure::GapDetector;

pub use cure::GapInfo;

pub use cure::RepairPipeline;

pub use cure::RepairReport;

pub use data::BalanceUpdatePoint;

pub use data::OrderUpdatePoint;

pub use data::PositionUpdatePoint;

Modules

backfill

REST backfill for warm-start.

bar_align

Bar-aligned historical series for non-OHLCV streams.

builder

cache

Cache layer — Phase 1: a thin Station-level wrapper around digdigdig3::core::rest_cache::RestCache keyed by (ExchangeId, AccountType, raw_symbol) for get_ticker.

cure

Dataset cure utilities — integrity check, deduplication, sequence-gap detection.

data

DataPoint implementations for each market-data class Station persists.

error

gap_heal

Auto-heal on WS disconnect — klines only.

normalize

STATION-side normalization over the RAW SymbolInfo core emits.

orderbook

OrderBookTracker — in-memory orderbook reconstruction from snapshot + delta stream.

persistence

Persistence configuration for the Station builder.

quota

Per-consumer subscription + REST rate quotas.

reconnect

Reconnect — phase 1 stub. Will hold gap-heal / silence-timeout overrides on top of the transport’s internal reconnect. See docs/plans/station-architecture.md §7.

replay

Phase ν — replay layer for dig3.

rest_cache

Generic TTL cache for REST responses (instrument metadata, exchange info, etc).

series

Unified time-series infrastructure for Station data-classes.

settings

General-purpose JSON settings/state persistence store.

station

storage

Storage subsystem — Phase μ.

subscription

ws_health

Structs

Credentials

Simple API key + secret credentials.

SymbolInfo

Информация о символе.

Enums

AccountType

Тип аккаунта/рынка

ExchangeId

Идентификатор биржи

Traits

PollSource

REST poll contract for one (kind, exchange, symbol) combination.