Skip to content

quantpylib.datapoller.base

BasePoller

A base class for creating pollers to interact with various data sources.

Attributes:

Name Type Description
pollers dict

A dictionary of pollers for different data sources.

default_src str

The default data source to be used.

stream_buffer defaultdict

A dictionary that stores deque instances for streaming data. Each call to stream_market_data from BasePoller instances will have the market-data streamed and appended in ascending (old to new) order to the stream_buffer, with length specified by buffer_len.

__init__(pollers, buffer_len=1000000000, default_src='')

Initialize the BasePoller with pollers, stream buffer length, and default data source.

Parameters:

Name Type Description Default
pollers dict

A dictionary of pollers for different data sources.

required
buffer_len int

Maximum length of the streaming buffer.

1000000000
default_src str

The default data source to be used.

''