Index

A

acquire() (RateLimiter method) active_runs() (RunsStore method) add_queue() (EventBus method)

aggregate_ohlc() (in module dccd.domain.transforms) alerts (AppConfig attribute) append_log() (RunsStore method) AsyncHTTPClient (class in dccd.transport.http)

B

backfill() (Client method) (in module dccd.application.operations) BinanceSource (class in dccd.sources.binance) BitfinexSource (class in dccd.sources.bitfinex)

BitMEXSource (class in dccd.sources.bitmex) build_registry() (in module dccd.application.service_factory) build_runs_store() (in module dccd.application.service_factory) build_store() (in module dccd.application.service_factory) BybitSource (class in dccd.sources.bybit)

C

capabilities() (BinanceSource method) (BitfinexSource method) (BitMEXSource method) (BybitSource method) (CoinbaseSource method) (KrakenSource method) (OKXSource method) (Source method)

Capability (class in dccd.domain.capability) capability_for() (Source method) Client (class in dccd) CoinbaseSource (class in dccd.sources.coinbase) CoverageError create_run() (RunsStore method) cron (JobConfig attribute)

D

data_path (SettingsConfig attribute) data_type (JobConfig attribute) DatasetId (class in dccd.domain.dataset) DataType (class in dccd.domain.types) dccd.application.events module dccd.application.jobs module dccd.application.operations module dccd.application.service_factory module dccd.domain.capability module dccd.domain.dataset module

dccd.domain.errors module dccd.domain.records module dccd.domain.symbol module dccd.domain.transforms module dccd.domain.types module dccd.sources.base module dccd.transport.paginate module DccdError depth (JobConfig attribute) directory() (ParquetStore method)

E

emit() (EventBus method) enable_queue() (EventBus method) EventBus (class in dccd.application.events)

every (JobConfig attribute) exchange (JobConfig attribute) exchanges (SourceRegistry property)

F

fetch_ohlc_page() (BinanceSource method) (BitfinexSource method) (BitMEXSource method) (BybitSource method) (CoinbaseSource method) (KrakenSource method) (OHLCHistory method) (OKXSource method) fetch_orderbook() (BinanceSource method) (BitfinexSource method) (BitMEXSource method) (BybitSource method) (CoinbaseSource method) (KrakenSource method) (OKXSource method) (OrderBookSnapshotREST method)

fetch_trades_page() (BinanceSource method) (BitfinexSource method) (BitMEXSource method) (CoinbaseSource method) (KrakenSource method) (OKXSource method) (TradesHistory method) finish_run() (RunsStore method) for_run() (EventBus method)

G

get() (AsyncHTTPClient method) (SourceRegistry method) get_ohlc_history() (SourceRegistry method) get_ohlc_live() (SourceRegistry method)

get_orderbook_live() (SourceRegistry method) get_orderbook_snapshot() (SourceRegistry method) get_run() (RunsStore method) get_trades_history() (SourceRegistry method) get_trades_live() (SourceRegistry method)

H

HTTPError

I

inventory() (Client method) (in module dccd.application.operations) (ParquetStore method)

J

JobParams (class in dccd.application.jobs) JobRun (class in dccd.application.jobs)

jobs (AppConfig attribute) JobSpec (class in dccd.application.jobs) JobTarget (class in dccd.application.jobs)

K

KrakenSource (class in dccd.sources.kraken)

L

last_timestamp() (ParquetStore method) list_runs() (RunsStore method)

load() (ParquetStore method) local_path (StorageConfig attribute) LogEvent (class in dccd.application.events)

M

make_id() (JobSpec class method) max_consecutive_errors (AlertConfig attribute) missing_intervals() (ParquetStore method) module dccd.application.events dccd.application.jobs dccd.application.operations dccd.application.service_factory dccd.domain.capability dccd.domain.dataset dccd.domain.errors dccd.domain.records dccd.domain.symbol dccd.domain.transforms dccd.domain.types dccd.sources.base dccd.transport.paginate

N

NoCapability

O

OHLCBar (class in dccd.domain.records) OHLCHistory (class in dccd.sources.base) OHLCLive (class in dccd.sources.base) OKXSource (class in dccd.sources.okx) on_connect() (WebSocketBase method)

operation (JobConfig attribute) OrderBookLevel (class in dccd.domain.records) OrderBookLive (class in dccd.sources.base) OrderBookSnapshot (class in dccd.domain.records) OrderBookSnapshotREST (class in dccd.sources.base)

P

paginate_backward() (in module dccd.transport.paginate) paginate_forward() (in module dccd.transport.paginate) paginate_ohlc() (in module dccd.transport.paginate) paginate_trades() (in module dccd.transport.paginate) pair_slug() (DatasetId method) pairs (JobConfig attribute)

ParquetStore (class in dccd.storage.parquet) parse() (Symbol class method) parse_message() (WebSocketBase method) ProgressEvent (class in dccd.application.events) Provenance (class in dccd.domain.dataset) provider (RemoteConfig attribute)

R

RateLimiter (class in dccd.transport.ratelimit) read() (Client method) (in module dccd.application.operations) read_provenance() (ParquetStore static method) register() (SourceRegistry method) register_streams() (Scheduler method) remote (RemoteConfig attribute) remotes (StorageConfig attribute) remove_queue() (EventBus method) render_symbol() (BinanceSource method) (BitfinexSource method) (BitMEXSource method) (BybitSource method) (CoinbaseSource method) (KrakenSource method) (OKXSource method) (Source method)

resolve() (SourceRegistry method) run_now() (Scheduler method) RunsStore (class in dccd.storage.runs_sqlite) RunState (class in dccd.application.jobs)

S

save() (ParquetStore method) Scheduler (class in dccd.application.scheduler) settings (AppConfig attribute) snapshot_interval (JobConfig attribute) Source (class in dccd.sources.base) SourceRegistry (class in dccd.sources.registry) span (JobConfig attribute) start (JobConfig attribute) start() (Scheduler method) start_stream() (Scheduler method) StatusEvent (class in dccd.application.events) stop() (Scheduler method) (WebSocketBase method) stop_stream() (Scheduler method) storage (AppConfig attribute) stream() (Client method) (in module dccd.application.operations) (WebSocketBase method) stream_ohlc() (BinanceSource method) (BitfinexSource method) (BitMEXSource method) (BybitSource method) (CoinbaseSource method) (KrakenSource method) (OHLCLive method) (OKXSource method)

stream_orderbook() (BinanceSource method) (BitfinexSource method) (BitMEXSource method) (BybitSource method) (CoinbaseSource method) (KrakenSource method) (OKXSource method) (OrderBookLive method) stream_raw() (WebSocketBase method) stream_status() (Scheduler method) stream_trades() (BinanceSource method) (BitfinexSource method) (BitMEXSource method) (BybitSource method) (CoinbaseSource method) (KrakenSource method) (OKXSource method) (TradesLive method) StreamSampleEvent (class in dccd.application.events) subscribe() (EventBus method) Symbol (class in dccd.domain.symbol) sync_interval (StorageConfig attribute) sync_intervals() (Scheduler method) sync_streams() (Scheduler method)

T

timezone (SettingsConfig attribute) Trade (class in dccd.domain.records) TradesHistory (class in dccd.sources.base)

TradesLive (class in dccd.sources.base) Trigger (class in dccd.application.jobs) trigger_kind (JobConfig attribute)

U

ui_allow_origins (SettingsConfig attribute) ui_auth_token (SettingsConfig attribute) ui_host (SettingsConfig attribute)

ui_port (SettingsConfig attribute) unsubscribe() (EventBus method) update_progress() (RunsStore method)

W

webhook_url (AlertConfig attribute)

WebSocketBase (class in dccd.transport.ws)