Index

_

__getattr__() (in module kuhl_haus.mdp.enum.market_data_cache_ttl) __init__() (kuhl_haus.mdp.analyzers.analyzer.Analyzer method) (kuhl_haus.mdp.analyzers.analyzer.AnalyzerOptions method) (kuhl_haus.mdp.analyzers.daily_range_analyzer.DailyRangeAnalyzer method) (kuhl_haus.mdp.analyzers.finlight_data_analyzer.FinlightDataAnalyzer method) (kuhl_haus.mdp.analyzers.leaderboard_analyzer.LeaderboardAnalyzer method) (kuhl_haus.mdp.analyzers.massive_data_analyzer.MassiveDataAnalyzer method) (kuhl_haus.mdp.analyzers.top_stocks.TopStocksAnalyzer method) (kuhl_haus.mdp.analyzers.top_trades_analyzer.TopTradesAnalyzer method) (kuhl_haus.mdp.components.finlight_data_listener.FinlightDataListener method) (kuhl_haus.mdp.components.finlight_data_processor.FinlightDataProcessor method) (kuhl_haus.mdp.components.finlight_data_queues.FinlightDataQueues method) (kuhl_haus.mdp.components.finlight_simple_listener.FinlightSimpleListener method) (kuhl_haus.mdp.components.market_data_cache.MarketDataCache method) (kuhl_haus.mdp.components.market_data_scanner.MarketDataScanner method) (kuhl_haus.mdp.components.massive_data_listener.MassiveDataListener method) (kuhl_haus.mdp.components.massive_data_processor.MassiveDataProcessor method) (kuhl_haus.mdp.components.massive_data_queues.MassiveDataQueues method) (kuhl_haus.mdp.components.widget_data_service.WidgetDataService method) (kuhl_haus.mdp.data.market_data_analyzer_result.MarketDataAnalyzerResult method) (kuhl_haus.mdp.data.top_stocks_cache_item.TopStocksCacheItem method) (kuhl_haus.mdp.exceptions.data_analysis_exception.DataAnalysisException method) (kuhl_haus.mdp.helpers.process_manager.ProcessManager method)

A

AGGREGATE (kuhl_haus.mdp.enum.market_data_cache_keys.MarketDataCacheKeys attribute) (kuhl_haus.mdp.enum.market_data_cache_ttl.MarketDataCacheTTL attribute) (kuhl_haus.mdp.enum.massive_data_queue.MassiveDataQueue attribute) analyze_data() (kuhl_haus.mdp.analyzers.analyzer.Analyzer method) (kuhl_haus.mdp.analyzers.daily_range_analyzer.DailyRangeAnalyzer method) (kuhl_haus.mdp.analyzers.finlight_data_analyzer.FinlightDataAnalyzer method) (kuhl_haus.mdp.analyzers.leaderboard_analyzer.LeaderboardAnalyzer method) (kuhl_haus.mdp.analyzers.massive_data_analyzer.MassiveDataAnalyzer method) (kuhl_haus.mdp.analyzers.top_stocks.TopStocksAnalyzer method) (kuhl_haus.mdp.analyzers.top_trades_analyzer.TopTradesAnalyzer method)

Analyzer (class in kuhl_haus.mdp.analyzers.analyzer) AnalyzerOptions (class in kuhl_haus.mdp.analyzers.analyzer) async_task() (kuhl_haus.mdp.components.massive_data_listener.MassiveDataListener method)

B

broadcast() (kuhl_haus.mdp.components.market_data_cache.MarketDataCache method)

C

cache (kuhl_haus.mdp.analyzers.leaderboard_analyzer.LeaderboardAnalyzer attribute) (kuhl_haus.mdp.analyzers.top_trades_analyzer.TopTradesAnalyzer attribute) cache_key (kuhl_haus.mdp.data.market_data_analyzer_result.MarketDataAnalyzerResult attribute) cache_list_max (kuhl_haus.mdp.data.market_data_analyzer_result.MarketDataAnalyzerResult attribute) cache_result() (kuhl_haus.mdp.components.market_data_scanner.MarketDataScanner method) cache_ttl (kuhl_haus.mdp.data.market_data_analyzer_result.MarketDataAnalyzerResult attribute) channels (kuhl_haus.mdp.components.finlight_data_queues.FinlightDataQueues attribute) (kuhl_haus.mdp.components.massive_data_queues.MassiveDataQueues attribute) CLOSED (kuhl_haus.mdp.enum.market_status_value.MarketStatusValue attribute) connect() (kuhl_haus.mdp.components.finlight_data_processor.FinlightDataProcessor method) (kuhl_haus.mdp.components.finlight_data_queues.FinlightDataQueues method) (kuhl_haus.mdp.components.market_data_scanner.MarketDataScanner method) (kuhl_haus.mdp.components.massive_data_processor.MassiveDataProcessor method) (kuhl_haus.mdp.components.massive_data_queues.MassiveDataQueues method)

connection (kuhl_haus.mdp.components.finlight_data_queues.FinlightDataQueues attribute) (kuhl_haus.mdp.components.massive_data_queues.MassiveDataQueues attribute) connection_status (kuhl_haus.mdp.components.finlight_data_listener.FinlightDataListener attribute) (kuhl_haus.mdp.components.finlight_data_queues.FinlightDataQueues attribute) (kuhl_haus.mdp.components.massive_data_listener.MassiveDataListener attribute) (kuhl_haus.mdp.components.massive_data_queues.MassiveDataQueues attribute)

D

DAILY_AGGREGATES (kuhl_haus.mdp.enum.market_data_cache_keys.MarketDataCacheKeys attribute) DAILY_RANGE (kuhl_haus.mdp.enum.widget_data_cache_keys.WidgetDataCacheKeys attribute) (kuhl_haus.mdp.enum.widget_data_cache_ttl.WidgetDataCacheTTL attribute) DAILY_RANGE_ALERT (kuhl_haus.mdp.enum.widget_data_cache_ttl.WidgetDataCacheTTL attribute) DAILY_RANGE_HOD_ALERT (kuhl_haus.mdp.enum.widget_data_cache_keys.WidgetDataCacheKeys attribute) DAILY_RANGE_LOD_ALERT (kuhl_haus.mdp.enum.widget_data_cache_keys.WidgetDataCacheKeys attribute) DailyRangeAnalyzer (class in kuhl_haus.mdp.analyzers.daily_range_analyzer) data (kuhl_haus.mdp.data.market_data_analyzer_result.MarketDataAnalyzerResult attribute) DataAnalysisException DAY_BOUNDARY_KEY (kuhl_haus.mdp.analyzers.daily_range_analyzer.DailyRangeAnalyzer attribute) day_start_time (kuhl_haus.mdp.data.top_stocks_cache_item.TopStocksCacheItem attribute) decode_equity_agg() (kuhl_haus.mdp.helpers.web_socket_message_serde.WebSocketMessageSerde static method)

decode_equity_quote() (kuhl_haus.mdp.helpers.web_socket_message_serde.WebSocketMessageSerde static method) decode_equity_trade() (kuhl_haus.mdp.helpers.web_socket_message_serde.WebSocketMessageSerde static method) decode_limit_up_limit_down() (kuhl_haus.mdp.helpers.web_socket_message_serde.WebSocketMessageSerde static method) decoding_error (kuhl_haus.mdp.components.finlight_data_processor.FinlightDataProcessor attribute) (kuhl_haus.mdp.components.market_data_scanner.MarketDataScanner attribute) (kuhl_haus.mdp.components.massive_data_processor.MassiveDataProcessor attribute) delete() (kuhl_haus.mdp.components.market_data_cache.MarketDataCache method) delete_ticker_snapshot() (kuhl_haus.mdp.components.market_data_cache.MarketDataCache method) deserialize() (kuhl_haus.mdp.helpers.web_socket_message_serde.WebSocketMessageSerde static method) disconnect() (kuhl_haus.mdp.components.widget_data_service.WidgetDataService method) DRA_CACHE_LIST_MAX (kuhl_haus.mdp.enum.widget_data_cache_limits.WidgetDataCacheLimits attribute) dropped (kuhl_haus.mdp.components.market_data_scanner.MarketDataScanner attribute)

E

ensure_logging_configured() (in module kuhl_haus.mdp.helpers.structured_logging) error (kuhl_haus.mdp.components.finlight_data_processor.FinlightDataProcessor attribute) (kuhl_haus.mdp.components.market_data_scanner.MarketDataScanner attribute) (kuhl_haus.mdp.components.massive_data_processor.MassiveDataProcessor attribute)

exchanges (kuhl_haus.mdp.components.finlight_data_queues.FinlightDataQueues attribute) (kuhl_haus.mdp.components.massive_data_queues.MassiveDataQueues attribute) EXTENDED_HOURS (kuhl_haus.mdp.enum.market_status_value.MarketStatusValue attribute)

F

feed (kuhl_haus.mdp.components.massive_data_listener.MassiveDataListener property) finlight_api_key (kuhl_haus.mdp.analyzers.analyzer.AnalyzerOptions attribute), [1] FinlightDataAnalyzer (class in kuhl_haus.mdp.analyzers.finlight_data_analyzer) FinlightDataCache (class in kuhl_haus.mdp.enum.finlight_data_cache)

FinlightDataListener (class in kuhl_haus.mdp.components.finlight_data_listener) FinlightDataProcessor (class in kuhl_haus.mdp.components.finlight_data_processor) FinlightDataQueue (class in kuhl_haus.mdp.enum.finlight_data_queue) FinlightDataQueues (class in kuhl_haus.mdp.components.finlight_data_queues) FinlightSimpleListener (class in kuhl_haus.mdp.components.finlight_simple_listener)

G

get_avg_volume() (kuhl_haus.mdp.components.market_data_cache.MarketDataCache method) get_cache() (kuhl_haus.mdp.components.market_data_scanner.MarketDataScanner method) (kuhl_haus.mdp.components.widget_data_service.WidgetDataService method) get_free_float() (kuhl_haus.mdp.components.market_data_cache.MarketDataCache method) get_logger() (in module kuhl_haus.mdp.helpers.structured_logging)

get_massive_api_key() (in module kuhl_haus.mdp.helpers.utils) get_meter() (in module kuhl_haus.mdp.helpers.observability) get_status() (kuhl_haus.mdp.helpers.process_manager.ProcessManager method) get_ticker_snapshot() (kuhl_haus.mdp.components.market_data_cache.MarketDataCache method) get_tracer() (in module kuhl_haus.mdp.helpers.observability)

H

HALTS (kuhl_haus.mdp.enum.market_data_cache_keys.MarketDataCacheKeys attribute) (kuhl_haus.mdp.enum.market_data_cache_ttl.MarketDataCacheTTL attribute) (kuhl_haus.mdp.enum.massive_data_queue.MassiveDataQueue attribute) handle_equity_agg() (kuhl_haus.mdp.analyzers.top_stocks.TopStocksAnalyzer method) handle_equity_agg_event() (kuhl_haus.mdp.analyzers.massive_data_analyzer.MassiveDataAnalyzer method)

handle_equity_quote_event() (kuhl_haus.mdp.analyzers.massive_data_analyzer.MassiveDataAnalyzer method) handle_equity_trade_event() (kuhl_haus.mdp.analyzers.massive_data_analyzer.MassiveDataAnalyzer method) handle_luld_event() (kuhl_haus.mdp.analyzers.massive_data_analyzer.MassiveDataAnalyzer method) handle_message() (kuhl_haus.mdp.components.finlight_data_queues.FinlightDataQueues method) handle_messages() (kuhl_haus.mdp.components.massive_data_queues.MassiveDataQueues method) handle_unknown_event() (kuhl_haus.mdp.analyzers.massive_data_analyzer.MassiveDataAnalyzer method)

I

include_entities (kuhl_haus.mdp.components.finlight_data_listener.FinlightDataListener attribute)

K

kuhl_haus module kuhl_haus.mdp module kuhl_haus.mdp.analyzers module kuhl_haus.mdp.analyzers.analyzer module kuhl_haus.mdp.analyzers.daily_range_analyzer module kuhl_haus.mdp.analyzers.finlight_data_analyzer module kuhl_haus.mdp.analyzers.leaderboard_analyzer module kuhl_haus.mdp.analyzers.massive_data_analyzer module kuhl_haus.mdp.analyzers.top_stocks module kuhl_haus.mdp.analyzers.top_trades_analyzer module kuhl_haus.mdp.components module kuhl_haus.mdp.components.finlight_data_listener module kuhl_haus.mdp.components.finlight_data_processor module kuhl_haus.mdp.components.finlight_data_queues module kuhl_haus.mdp.components.finlight_simple_listener module kuhl_haus.mdp.components.market_data_cache module kuhl_haus.mdp.components.market_data_scanner module kuhl_haus.mdp.components.massive_data_listener module kuhl_haus.mdp.components.massive_data_processor module kuhl_haus.mdp.components.massive_data_queues module kuhl_haus.mdp.components.widget_data_service module kuhl_haus.mdp.data module kuhl_haus.mdp.data.market_data_analyzer_result module kuhl_haus.mdp.data.top_stocks_cache_item module

kuhl_haus.mdp.enum module kuhl_haus.mdp.enum.constants module kuhl_haus.mdp.enum.finlight_data_cache module kuhl_haus.mdp.enum.finlight_data_queue module kuhl_haus.mdp.enum.market_data_cache_keys module kuhl_haus.mdp.enum.market_data_cache_ttl module kuhl_haus.mdp.enum.market_data_pubsub_keys module kuhl_haus.mdp.enum.market_data_scanner_names module kuhl_haus.mdp.enum.market_status_value module kuhl_haus.mdp.enum.massive_data_queue module kuhl_haus.mdp.enum.widget_data_cache_keys module kuhl_haus.mdp.enum.widget_data_cache_limits module kuhl_haus.mdp.enum.widget_data_cache_ttl module kuhl_haus.mdp.exceptions module kuhl_haus.mdp.exceptions.data_analysis_exception module kuhl_haus.mdp.helpers module kuhl_haus.mdp.helpers.observability module kuhl_haus.mdp.helpers.process_manager module kuhl_haus.mdp.helpers.queue_name_resolver module kuhl_haus.mdp.helpers.serde module kuhl_haus.mdp.helpers.structured_logging module kuhl_haus.mdp.helpers.utils module kuhl_haus.mdp.helpers.web_socket_message_serde module kwargs (kuhl_haus.mdp.analyzers.analyzer.AnalyzerOptions attribute), [1]

L

language (kuhl_haus.mdp.components.finlight_data_listener.FinlightDataListener property) LEADERBOARD_ANALYZER (kuhl_haus.mdp.enum.market_data_cache_ttl.MarketDataCacheTTL attribute) LEADERBOARD_MARKET_DAY_KEY (kuhl_haus.mdp.enum.market_data_cache_keys.MarketDataCacheKeys attribute) LEADERBOARD_MARKET_OPEN_RESET_KEY (kuhl_haus.mdp.enum.market_data_cache_keys.MarketDataCacheKeys attribute) LEADERBOARD_PUBLISH_THROTTLE_KEY (kuhl_haus.mdp.enum.market_data_cache_keys.MarketDataCacheKeys attribute) LEADERBOARD_TOP_GAINERS (kuhl_haus.mdp.analyzers.leaderboard_analyzer.LeaderboardAnalyzer attribute) (kuhl_haus.mdp.enum.market_data_cache_keys.MarketDataCacheKeys attribute) (kuhl_haus.mdp.enum.market_data_cache_ttl.MarketDataCacheTTL attribute)

LEADERBOARD_TOP_GAPPERS (kuhl_haus.mdp.analyzers.leaderboard_analyzer.LeaderboardAnalyzer attribute) (kuhl_haus.mdp.enum.market_data_cache_keys.MarketDataCacheKeys attribute) (kuhl_haus.mdp.enum.market_data_cache_ttl.MarketDataCacheTTL attribute) LEADERBOARD_TOP_VOLUME (kuhl_haus.mdp.analyzers.leaderboard_analyzer.LeaderboardAnalyzer attribute) (kuhl_haus.mdp.enum.market_data_cache_keys.MarketDataCacheKeys attribute) (kuhl_haus.mdp.enum.market_data_cache_ttl.MarketDataCacheTTL attribute) LeaderboardAnalyzer (class in kuhl_haus.mdp.analyzers.leaderboard_analyzer) log_exception() (in module kuhl_haus.mdp.helpers.structured_logging)

M

market (kuhl_haus.mdp.components.massive_data_listener.MassiveDataListener property) MARKET_DAY_KEY (kuhl_haus.mdp.analyzers.leaderboard_analyzer.LeaderboardAnalyzer attribute) market_is_open() (kuhl_haus.mdp.components.massive_data_listener.MassiveDataListener method) MARKET_OPEN_RESET_KEY (kuhl_haus.mdp.analyzers.leaderboard_analyzer.LeaderboardAnalyzer attribute) MarketDataAnalyzerResult (class in kuhl_haus.mdp.data.market_data_analyzer_result) MarketDataCache (class in kuhl_haus.mdp.components.market_data_cache) MarketDataCacheKeys (class in kuhl_haus.mdp.enum.market_data_cache_keys) MarketDataCacheTTL (class in kuhl_haus.mdp.enum.market_data_cache_ttl) MarketDataPubSubKeys (class in kuhl_haus.mdp.enum.market_data_pubsub_keys) MarketDataScanner (class in kuhl_haus.mdp.components.market_data_scanner) MarketDataScannerNames (class in kuhl_haus.mdp.enum.market_data_scanner_names) MarketStatusValue (class in kuhl_haus.mdp.enum.market_status_value) massive_api_key (kuhl_haus.mdp.analyzers.analyzer.AnalyzerOptions attribute), [1] MassiveDataAnalyzer (class in kuhl_haus.mdp.analyzers.massive_data_analyzer) MassiveDataListener (class in kuhl_haus.mdp.components.massive_data_listener) MassiveDataProcessor (class in kuhl_haus.mdp.components.massive_data_processor) MassiveDataQueue (class in kuhl_haus.mdp.enum.massive_data_queue) MassiveDataQueues (class in kuhl_haus.mdp.components.massive_data_queues) max_reconnects (kuhl_haus.mdp.components.finlight_data_listener.FinlightDataListener attribute) (kuhl_haus.mdp.components.massive_data_listener.MassiveDataListener attribute) MAX_TRADES_PER_SYMBOL (kuhl_haus.mdp.analyzers.top_trades_analyzer.TopTradesAnalyzer attribute) mdc_connected (kuhl_haus.mdp.components.finlight_data_processor.FinlightDataProcessor attribute) (kuhl_haus.mdp.components.market_data_scanner.MarketDataScanner attribute) (kuhl_haus.mdp.components.massive_data_processor.MassiveDataProcessor attribute) mdq_connected (kuhl_haus.mdp.components.finlight_data_processor.FinlightDataProcessor attribute) (kuhl_haus.mdp.components.massive_data_processor.MassiveDataProcessor attribute) message_ttl (kuhl_haus.mdp.components.finlight_data_queues.FinlightDataQueues attribute) (kuhl_haus.mdp.components.massive_data_queues.MassiveDataQueues attribute) module kuhl_haus kuhl_haus.mdp kuhl_haus.mdp.analyzers kuhl_haus.mdp.analyzers.analyzer kuhl_haus.mdp.analyzers.daily_range_analyzer kuhl_haus.mdp.analyzers.finlight_data_analyzer kuhl_haus.mdp.analyzers.leaderboard_analyzer kuhl_haus.mdp.analyzers.massive_data_analyzer kuhl_haus.mdp.analyzers.top_stocks kuhl_haus.mdp.analyzers.top_trades_analyzer kuhl_haus.mdp.components kuhl_haus.mdp.components.finlight_data_listener kuhl_haus.mdp.components.finlight_data_processor kuhl_haus.mdp.components.finlight_data_queues kuhl_haus.mdp.components.finlight_simple_listener kuhl_haus.mdp.components.market_data_cache kuhl_haus.mdp.components.market_data_scanner kuhl_haus.mdp.components.massive_data_listener kuhl_haus.mdp.components.massive_data_processor kuhl_haus.mdp.components.massive_data_queues kuhl_haus.mdp.components.widget_data_service kuhl_haus.mdp.data kuhl_haus.mdp.data.market_data_analyzer_result kuhl_haus.mdp.data.top_stocks_cache_item kuhl_haus.mdp.enum kuhl_haus.mdp.enum.constants kuhl_haus.mdp.enum.finlight_data_cache kuhl_haus.mdp.enum.finlight_data_queue kuhl_haus.mdp.enum.market_data_cache_keys kuhl_haus.mdp.enum.market_data_cache_ttl kuhl_haus.mdp.enum.market_data_pubsub_keys kuhl_haus.mdp.enum.market_data_scanner_names kuhl_haus.mdp.enum.market_status_value kuhl_haus.mdp.enum.massive_data_queue kuhl_haus.mdp.enum.widget_data_cache_keys kuhl_haus.mdp.enum.widget_data_cache_limits kuhl_haus.mdp.enum.widget_data_cache_ttl kuhl_haus.mdp.exceptions kuhl_haus.mdp.exceptions.data_analysis_exception kuhl_haus.mdp.helpers kuhl_haus.mdp.helpers.observability kuhl_haus.mdp.helpers.process_manager kuhl_haus.mdp.helpers.queue_name_resolver kuhl_haus.mdp.helpers.serde kuhl_haus.mdp.helpers.structured_logging kuhl_haus.mdp.helpers.utils kuhl_haus.mdp.helpers.web_socket_message_serde

N

NEGATIVE_CACHE_SESSION (kuhl_haus.mdp.enum.market_data_cache_ttl.MarketDataCacheTTL attribute) NEGATIVE_CACHE_THROTTLE (kuhl_haus.mdp.enum.market_data_cache_ttl.MarketDataCacheTTL attribute) new_finlight_client() (kuhl_haus.mdp.analyzers.analyzer.AnalyzerOptions method) new_redis_client() (kuhl_haus.mdp.analyzers.analyzer.AnalyzerOptions method) new_rest_client() (kuhl_haus.mdp.analyzers.analyzer.AnalyzerOptions method) NEWS (kuhl_haus.mdp.enum.finlight_data_queue.FinlightDataQueue attribute) NEWS_FEED_LATEST (kuhl_haus.mdp.enum.market_data_cache_ttl.MarketDataCacheTTL attribute) (kuhl_haus.mdp.enum.market_data_pubsub_keys.MarketDataPubSubKeys attribute) (kuhl_haus.mdp.enum.widget_data_cache_keys.WidgetDataCacheKeys attribute) (kuhl_haus.mdp.enum.widget_data_cache_ttl.WidgetDataCacheTTL attribute)

NEWS_FEED_LIST_MAX (kuhl_haus.mdp.enum.finlight_data_cache.FinlightDataCache attribute) NEWS_TICKER (kuhl_haus.mdp.enum.market_data_cache_ttl.MarketDataCacheTTL attribute) (kuhl_haus.mdp.enum.market_data_pubsub_keys.MarketDataPubSubKeys attribute) (kuhl_haus.mdp.enum.widget_data_cache_keys.WidgetDataCacheKeys attribute) (kuhl_haus.mdp.enum.widget_data_cache_ttl.WidgetDataCacheTTL attribute) NEWS_TICKER_LIST_MAX (kuhl_haus.mdp.enum.finlight_data_cache.FinlightDataCache attribute)

O

OPEN (kuhl_haus.mdp.enum.market_status_value.MarketStatusValue attribute)

options (kuhl_haus.mdp.analyzers.analyzer.Analyzer attribute)

P

processed (kuhl_haus.mdp.components.finlight_data_processor.FinlightDataProcessor attribute) (kuhl_haus.mdp.components.market_data_scanner.MarketDataScanner attribute) (kuhl_haus.mdp.components.massive_data_processor.MassiveDataProcessor attribute) processing_error (kuhl_haus.mdp.components.finlight_data_processor.FinlightDataProcessor attribute) (kuhl_haus.mdp.components.massive_data_processor.MassiveDataProcessor attribute) ProcessManager (class in kuhl_haus.mdp.helpers.process_manager) PUBLISH_INTERVAL (kuhl_haus.mdp.analyzers.top_trades_analyzer.TopTradesAnalyzer attribute)

publish_key (kuhl_haus.mdp.data.market_data_analyzer_result.MarketDataAnalyzerResult attribute) PUBLISH_THROTTLE_KEY (kuhl_haus.mdp.analyzers.leaderboard_analyzer.LeaderboardAnalyzer attribute) (kuhl_haus.mdp.analyzers.top_trades_analyzer.TopTradesAnalyzer attribute) published (kuhl_haus.mdp.components.finlight_data_processor.FinlightDataProcessor attribute) (kuhl_haus.mdp.components.massive_data_processor.MassiveDataProcessor attribute) publisher_confirms (kuhl_haus.mdp.components.finlight_data_queues.FinlightDataQueues attribute) (kuhl_haus.mdp.components.massive_data_queues.MassiveDataQueues attribute)

Q

query (kuhl_haus.mdp.components.finlight_data_listener.FinlightDataListener property) queue_name (kuhl_haus.mdp.components.finlight_data_processor.FinlightDataProcessor attribute) (kuhl_haus.mdp.components.massive_data_processor.MassiveDataProcessor attribute) queue_name_for_web_socket_message() (kuhl_haus.mdp.helpers.queue_name_resolver.QueueNameResolver static method) QueueNameResolver (class in kuhl_haus.mdp.helpers.queue_name_resolver) queues (kuhl_haus.mdp.components.finlight_data_queues.FinlightDataQueues attribute) (kuhl_haus.mdp.components.massive_data_queues.MassiveDataQueues attribute)

QUOTE (kuhl_haus.mdp.enum.market_data_cache_ttl.MarketDataCacheTTL attribute) (kuhl_haus.mdp.enum.market_data_pubsub_keys.MarketDataPubSubKeys attribute) (kuhl_haus.mdp.enum.widget_data_cache_keys.WidgetDataCacheKeys attribute) (kuhl_haus.mdp.enum.widget_data_cache_ttl.WidgetDataCacheTTL attribute) QUOTES (kuhl_haus.mdp.enum.market_data_cache_keys.MarketDataCacheKeys attribute) (kuhl_haus.mdp.enum.market_data_cache_ttl.MarketDataCacheTTL attribute) (kuhl_haus.mdp.enum.massive_data_queue.MassiveDataQueue attribute)

R

rabbitmq_url (kuhl_haus.mdp.components.finlight_data_queues.FinlightDataQueues attribute) (kuhl_haus.mdp.components.massive_data_queues.MassiveDataQueues attribute) raw (kuhl_haus.mdp.components.finlight_data_listener.FinlightDataListener attribute) (kuhl_haus.mdp.components.massive_data_listener.MassiveDataListener attribute) read() (kuhl_haus.mdp.components.market_data_cache.MarketDataCache method) redis_url (kuhl_haus.mdp.analyzers.analyzer.AnalyzerOptions attribute), [1] rehydrate() (kuhl_haus.mdp.analyzers.analyzer.Analyzer method) (kuhl_haus.mdp.analyzers.daily_range_analyzer.DailyRangeAnalyzer method) (kuhl_haus.mdp.analyzers.finlight_data_analyzer.FinlightDataAnalyzer method) (kuhl_haus.mdp.analyzers.top_stocks.TopStocksAnalyzer method)

restart() (kuhl_haus.mdp.components.finlight_data_listener.FinlightDataListener method) (kuhl_haus.mdp.components.market_data_scanner.MarketDataScanner method) (kuhl_haus.mdp.components.massive_data_listener.MassiveDataListener method) restarts (kuhl_haus.mdp.components.market_data_scanner.MarketDataScanner attribute)

S

secure (kuhl_haus.mdp.components.massive_data_listener.MassiveDataListener attribute) serialize() (kuhl_haus.mdp.helpers.web_socket_message_serde.WebSocketMessageSerde static method) serialize_equity_agg() (kuhl_haus.mdp.helpers.web_socket_message_serde.WebSocketMessageSerde static method) serialize_equity_quote() (kuhl_haus.mdp.helpers.web_socket_message_serde.WebSocketMessageSerde static method) serialize_equity_trade() (kuhl_haus.mdp.helpers.web_socket_message_serde.WebSocketMessageSerde static method) serialize_limit_up_limit_down() (kuhl_haus.mdp.helpers.web_socket_message_serde.WebSocketMessageSerde static method) setup_logging() (in module kuhl_haus.mdp.helpers.structured_logging) setup_queues() (kuhl_haus.mdp.components.finlight_data_queues.FinlightDataQueues method) (kuhl_haus.mdp.components.massive_data_queues.MassiveDataQueues method) shutdown() (kuhl_haus.mdp.components.finlight_data_queues.FinlightDataQueues method) (kuhl_haus.mdp.components.massive_data_queues.MassiveDataQueues method) SMALL_CAP_HOD_MOMO (kuhl_haus.mdp.enum.market_data_scanner_names.MarketDataScannerNames attribute) sources (kuhl_haus.mdp.components.finlight_data_listener.FinlightDataListener property) start() (kuhl_haus.mdp.components.finlight_data_listener.FinlightDataListener method) (kuhl_haus.mdp.components.finlight_data_processor.FinlightDataProcessor method) (kuhl_haus.mdp.components.finlight_simple_listener.FinlightSimpleListener method) (kuhl_haus.mdp.components.market_data_scanner.MarketDataScanner method) (kuhl_haus.mdp.components.massive_data_listener.MassiveDataListener method) (kuhl_haus.mdp.components.massive_data_processor.MassiveDataProcessor method) (kuhl_haus.mdp.components.widget_data_service.WidgetDataService method)

start_worker() (kuhl_haus.mdp.helpers.process_manager.ProcessManager method) stop() (kuhl_haus.mdp.components.finlight_data_listener.FinlightDataListener method) (kuhl_haus.mdp.components.finlight_data_processor.FinlightDataProcessor method) (kuhl_haus.mdp.components.finlight_simple_listener.FinlightSimpleListener method) (kuhl_haus.mdp.components.market_data_scanner.MarketDataScanner method) (kuhl_haus.mdp.components.massive_data_listener.MassiveDataListener method) (kuhl_haus.mdp.components.massive_data_processor.MassiveDataProcessor method) (kuhl_haus.mdp.components.widget_data_service.WidgetDataService method) stop_all() (kuhl_haus.mdp.helpers.process_manager.ProcessManager method) stop_process() (kuhl_haus.mdp.helpers.process_manager.ProcessManager method) subscribe() (kuhl_haus.mdp.components.widget_data_service.WidgetDataService method) subscriptions (kuhl_haus.mdp.components.massive_data_listener.MassiveDataListener property) symbol_data_cache (kuhl_haus.mdp.data.top_stocks_cache_item.TopStocksCacheItem attribute)

T

TICKER_AVG_VOLUME (kuhl_haus.mdp.enum.market_data_cache_keys.MarketDataCacheKeys attribute) (kuhl_haus.mdp.enum.market_data_cache_ttl.MarketDataCacheTTL attribute) TICKER_AVG_VOLUME_LOCK (kuhl_haus.mdp.enum.market_data_cache_keys.MarketDataCacheKeys attribute) (kuhl_haus.mdp.enum.market_data_cache_ttl.MarketDataCacheTTL attribute) TICKER_FREE_FLOAT (kuhl_haus.mdp.enum.market_data_cache_keys.MarketDataCacheKeys attribute) (kuhl_haus.mdp.enum.market_data_cache_ttl.MarketDataCacheTTL attribute) TICKER_FREE_FLOAT_LOCK (kuhl_haus.mdp.enum.market_data_cache_keys.MarketDataCacheKeys attribute) (kuhl_haus.mdp.enum.market_data_cache_ttl.MarketDataCacheTTL attribute) TICKER_SNAPSHOT_LOCK (kuhl_haus.mdp.enum.market_data_cache_keys.MarketDataCacheKeys attribute) (kuhl_haus.mdp.enum.market_data_cache_ttl.MarketDataCacheTTL attribute) ticker_snapshot_to_dict() (in module kuhl_haus.mdp.helpers.utils) TICKER_SNAPSHOTS (kuhl_haus.mdp.enum.market_data_cache_keys.MarketDataCacheKeys attribute) (kuhl_haus.mdp.enum.market_data_cache_ttl.MarketDataCacheTTL attribute) tickers (kuhl_haus.mdp.components.finlight_data_listener.FinlightDataListener property) to_dict() (in module kuhl_haus.mdp.helpers.serde) (kuhl_haus.mdp.data.top_stocks_cache_item.TopStocksCacheItem method) (kuhl_haus.mdp.helpers.web_socket_message_serde.WebSocketMessageSerde static method) TOP_10_LISTS_SCANNER (kuhl_haus.mdp.enum.market_data_pubsub_keys.MarketDataPubSubKeys attribute) (kuhl_haus.mdp.enum.widget_data_cache_keys.WidgetDataCacheKeys attribute) TOP_GAINERS (kuhl_haus.mdp.enum.market_data_scanner_names.MarketDataScannerNames attribute) top_gainers() (kuhl_haus.mdp.data.top_stocks_cache_item.TopStocksCacheItem method) top_gainers_map (kuhl_haus.mdp.data.top_stocks_cache_item.TopStocksCacheItem attribute) TOP_GAINERS_SCANNER (kuhl_haus.mdp.enum.market_data_cache_keys.MarketDataCacheKeys attribute) (kuhl_haus.mdp.enum.market_data_cache_ttl.MarketDataCacheTTL attribute) (kuhl_haus.mdp.enum.market_data_pubsub_keys.MarketDataPubSubKeys attribute) (kuhl_haus.mdp.enum.widget_data_cache_keys.WidgetDataCacheKeys attribute) (kuhl_haus.mdp.enum.widget_data_cache_ttl.WidgetDataCacheTTL attribute) TOP_GAPPERS (kuhl_haus.mdp.enum.market_data_scanner_names.MarketDataScannerNames attribute) top_gappers() (kuhl_haus.mdp.data.top_stocks_cache_item.TopStocksCacheItem method) top_gappers_map (kuhl_haus.mdp.data.top_stocks_cache_item.TopStocksCacheItem attribute) TOP_GAPPERS_SCANNER (kuhl_haus.mdp.enum.market_data_cache_keys.MarketDataCacheKeys attribute) (kuhl_haus.mdp.enum.market_data_cache_ttl.MarketDataCacheTTL attribute) (kuhl_haus.mdp.enum.market_data_pubsub_keys.MarketDataPubSubKeys attribute) (kuhl_haus.mdp.enum.widget_data_cache_keys.WidgetDataCacheKeys attribute) (kuhl_haus.mdp.enum.widget_data_cache_ttl.WidgetDataCacheTTL attribute) TOP_STOCKS (kuhl_haus.mdp.enum.market_data_scanner_names.MarketDataScannerNames attribute) TOP_STOCKS_SCANNER (kuhl_haus.mdp.enum.market_data_cache_keys.MarketDataCacheKeys attribute) (kuhl_haus.mdp.enum.market_data_cache_ttl.MarketDataCacheTTL attribute) (kuhl_haus.mdp.enum.widget_data_cache_keys.WidgetDataCacheKeys attribute) (kuhl_haus.mdp.enum.widget_data_cache_ttl.WidgetDataCacheTTL attribute) TOP_TRADES (kuhl_haus.mdp.enum.market_data_scanner_names.MarketDataScannerNames attribute)

TOP_TRADES_ALL_SYMBOLS_CACHE_KEY (kuhl_haus.mdp.analyzers.top_trades_analyzer.TopTradesAnalyzer attribute) (kuhl_haus.mdp.enum.market_data_cache_keys.MarketDataCacheKeys attribute) (kuhl_haus.mdp.enum.widget_data_cache_keys.WidgetDataCacheKeys attribute) TOP_TRADES_ALL_SYMBOLS_CACHE_TTL (kuhl_haus.mdp.analyzers.top_trades_analyzer.TopTradesAnalyzer attribute) (kuhl_haus.mdp.enum.market_data_cache_ttl.MarketDataCacheTTL attribute) (kuhl_haus.mdp.enum.widget_data_cache_ttl.WidgetDataCacheTTL attribute) TOP_TRADES_LAST_PUBLISH_KEY (kuhl_haus.mdp.enum.market_data_cache_keys.MarketDataCacheKeys attribute) TOP_TRADES_RECENT_PREFIX (kuhl_haus.mdp.enum.market_data_cache_keys.MarketDataCacheKeys attribute) TOP_TRADES_RECENT_SCAN (kuhl_haus.mdp.enum.market_data_cache_keys.MarketDataCacheKeys attribute) TOP_TRADES_SCANNER (kuhl_haus.mdp.enum.market_data_cache_keys.MarketDataCacheKeys attribute) (kuhl_haus.mdp.enum.widget_data_cache_keys.WidgetDataCacheKeys attribute) TOP_TRADES_SCANNER_FIVE_MINUTES (kuhl_haus.mdp.enum.market_data_pubsub_keys.MarketDataPubSubKeys attribute) (kuhl_haus.mdp.enum.widget_data_cache_keys.WidgetDataCacheKeys attribute) TOP_TRADES_SCANNER_ONE_HOUR (kuhl_haus.mdp.enum.market_data_pubsub_keys.MarketDataPubSubKeys attribute) (kuhl_haus.mdp.enum.widget_data_cache_keys.WidgetDataCacheKeys attribute) TOP_TRADES_SCANNER_ONE_MINUTE (kuhl_haus.mdp.enum.market_data_pubsub_keys.MarketDataPubSubKeys attribute) (kuhl_haus.mdp.enum.widget_data_cache_keys.WidgetDataCacheKeys attribute) TOP_TRADES_STATS_PREFIX (kuhl_haus.mdp.enum.market_data_cache_keys.MarketDataCacheKeys attribute) TOP_TRADES_TRADE_TTL (kuhl_haus.mdp.enum.market_data_cache_ttl.MarketDataCacheTTL attribute) TOP_TRADES_WIDGET_CACHE_KEY (kuhl_haus.mdp.analyzers.top_trades_analyzer.TopTradesAnalyzer attribute) (kuhl_haus.mdp.enum.market_data_cache_keys.MarketDataCacheKeys attribute) (kuhl_haus.mdp.enum.widget_data_cache_keys.WidgetDataCacheKeys attribute) TOP_TRADES_WIDGET_CACHE_TTL (kuhl_haus.mdp.analyzers.top_trades_analyzer.TopTradesAnalyzer attribute) (kuhl_haus.mdp.enum.market_data_cache_ttl.MarketDataCacheTTL attribute) (kuhl_haus.mdp.enum.widget_data_cache_ttl.WidgetDataCacheTTL attribute) TOP_VOLUME (kuhl_haus.mdp.enum.market_data_scanner_names.MarketDataScannerNames attribute) top_volume() (kuhl_haus.mdp.data.top_stocks_cache_item.TopStocksCacheItem method) top_volume_map (kuhl_haus.mdp.data.top_stocks_cache_item.TopStocksCacheItem attribute) TOP_VOLUME_SCANNER (kuhl_haus.mdp.enum.market_data_cache_keys.MarketDataCacheKeys attribute) (kuhl_haus.mdp.enum.market_data_cache_ttl.MarketDataCacheTTL attribute) (kuhl_haus.mdp.enum.market_data_pubsub_keys.MarketDataPubSubKeys attribute) (kuhl_haus.mdp.enum.widget_data_cache_keys.WidgetDataCacheKeys attribute) (kuhl_haus.mdp.enum.widget_data_cache_ttl.WidgetDataCacheTTL attribute) TopStocksAnalyzer (class in kuhl_haus.mdp.analyzers.top_stocks) TopStocksCacheItem (class in kuhl_haus.mdp.data.top_stocks_cache_item) TopTradesAnalyzer (class in kuhl_haus.mdp.analyzers.top_trades_analyzer) TRADE_TTL (kuhl_haus.mdp.analyzers.top_trades_analyzer.TopTradesAnalyzer attribute) TRADES (kuhl_haus.mdp.enum.market_data_cache_keys.MarketDataCacheKeys attribute) (kuhl_haus.mdp.enum.market_data_cache_ttl.MarketDataCacheTTL attribute) (kuhl_haus.mdp.enum.massive_data_queue.MassiveDataQueue attribute) TRADES_RECENT_PREFIX (kuhl_haus.mdp.analyzers.top_trades_analyzer.TopTradesAnalyzer attribute) TRADES_STATS_PREFIX (kuhl_haus.mdp.analyzers.top_trades_analyzer.TopTradesAnalyzer attribute)

U

UnauthorizedException UNKNOWN (kuhl_haus.mdp.enum.market_data_cache_keys.MarketDataCacheKeys attribute) (kuhl_haus.mdp.enum.market_data_cache_ttl.MarketDataCacheTTL attribute) (kuhl_haus.mdp.enum.massive_data_queue.MassiveDataQueue attribute)

unsubscribe() (kuhl_haus.mdp.components.widget_data_service.WidgetDataService method)

V

verbose (kuhl_haus.mdp.components.massive_data_listener.MassiveDataListener attribute)

W

WebSocketMessageSerde (class in kuhl_haus.mdp.helpers.web_socket_message_serde) WidgetDataCacheKeys (class in kuhl_haus.mdp.enum.widget_data_cache_keys) WidgetDataCacheLimits (class in kuhl_haus.mdp.enum.widget_data_cache_limits) WidgetDataCacheTTL (class in kuhl_haus.mdp.enum.widget_data_cache_ttl)

WidgetDataService (class in kuhl_haus.mdp.components.widget_data_service) write() (kuhl_haus.mdp.components.market_data_cache.MarketDataCache method) ws_connection (kuhl_haus.mdp.components.massive_data_listener.MassiveDataListener attribute) ws_coroutine (kuhl_haus.mdp.components.massive_data_listener.MassiveDataListener attribute)