pyokx.redis_structured_streams

async pyokx.redis_structured_streams.get_instruments_searcher_from_redis(async_redis: Redis) → InstrumentSearcher[source]

async pyokx.redis_structured_streams.get_okx_fills_history(redis_client, count: int = 10) → List[List[FillEntry]][source]

async pyokx.redis_structured_streams.get_stream_okx_account_messages(async_redis: Redis, count: int = 10) → List[AccountChannel][source]: Uses xrevrange to get the latest COUNT account messages from redis and return all COUNT messages in a list from oldest to newest

async pyokx.redis_structured_streams.get_stream_okx_all_messages(async_redis: Redis, count: int = 10) → List[source]

async pyokx.redis_structured_streams.get_stream_okx_fill_metrics_report(async_redis: Redis, count: int = 10) → List[FillHistoricalMetrics][source]

async pyokx.redis_structured_streams.get_stream_okx_incomplete_algo_orders(async_redis: Redis, count: int = 1) → List[List[Algo_Order]][source]

async pyokx.redis_structured_streams.get_stream_okx_incomplete_orders(async_redis: Redis, count: int = 1) → List[List[Order]][source]

async pyokx.redis_structured_streams.get_stream_okx_order_messages(async_redis: Redis, count: int = 10) → List[OrdersChannel][source]

async pyokx.redis_structured_streams.get_stream_okx_position_messages(async_redis: Redis, count: int = 10) → List[PositionsChannel][source]