Exchange.Adapters.InMemoryTimeSeries (Exchange v0.2.6) View Source

Public API to use the adapter of Exchange.TimeSeries, the InMemoryTimeSeries. This adapter is an approach of an in memory time series database and it keeps state about orders, prices and trades.

Link to this section Summary

Functions

cast_event(event, payload)

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

completed_trades(ticker)

Callback implementation for Exchange.TimeSeries.completed_trades/1.

completed_trades_by_id(ticker, trader_id)

Callback implementation for Exchange.TimeSeries.completed_trades_by_id/2.

flush()

get_completed_trade_by_trade_id(ticker, trade_id)

Callback implementation for Exchange.TimeSeries.get_completed_trade_by_trade_id/2.

get_live_orders(ticker)

Callback implementation for Exchange.TimeSeries.get_live_orders/1.

get_state()

init()

Callback implementation for Exchange.TimeSeries.init/0.

init(state)

Callback implementation for GenServer.init/1.

save(item, timestamp, state_map)

save_order(order, state)

save_price(price, state)

save_trade(trade, state)

start_link(_)

validate_config(config \\ [])

validate_dependency()

Link to this section Functions

cast_event(event, payload)

Specs

cast_event(event :: atom(), payload :: Exchange.Adapters.MessageBus.*()) ::
  Exchange.Adapters.MessageBus.*()

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

completed_trades(ticker)

Specs

completed_trades(ticker :: atom()) :: [Exchange.Trade]

Callback implementation for Exchange.TimeSeries.completed_trades/1.

completed_trades_by_id(ticker, trader_id)

Specs

completed_trades_by_id(ticker :: atom(), trader_id :: String.t()) :: [
  Exchange.Trade
]

Callback implementation for Exchange.TimeSeries.completed_trades_by_id/2.

flush()

get_completed_trade_by_trade_id(ticker, trade_id)

Specs

get_completed_trade_by_trade_id(ticker :: atom(), trade_id :: String.t()) ::
  Exchange.Trade

Callback implementation for Exchange.TimeSeries.get_completed_trade_by_trade_id/2.

get_live_orders(ticker)

Specs

get_live_orders(ticker :: atom()) :: [Exchange.Order]

Callback implementation for Exchange.TimeSeries.get_live_orders/1.

get_state()

Specs

get_state() :: map()

init()

Callback implementation for Exchange.TimeSeries.init/0.

init(state)

Callback implementation for GenServer.init/1.

save(item, timestamp, state_map)

Specs

save(item :: any(), timestamp :: number(), state :: map()) :: map()

save_order(order, state)

Specs

save_order(Exchange.Order.order(), map()) :: map()

save_price(price, state)

Specs

save_price(price :: map(), state :: map()) :: map()

save_trade(trade, state)

Specs

save_trade(trade :: Exchange.Trade, state :: map()) :: map()

start_link(_)

validate_config(config \\ [])