Lean
$LEAN_TAG$
|
Processor for caching and consolidating ticks; then flushing the ticks in memory to disk when triggered. More...
Public Member Functions | |
bool | ShouldWriteToDisk () |
If no data has been consolidated, do not write to disk More... | |
AlgoSeekFuturesProcessor (Symbol symbol, DateTime date, TickType tickType, Resolution resolution, string dataDirectory) | |
Create a new AlgoSeekFuturesProcessor for enquing consolidated bars and flushing them to disk More... | |
void | Process (Tick data) |
Process the tick; add to the con More... | |
void | FlushBuffer (DateTime frontierTime, bool finalFlush) |
Write the in memory queues to the disk. More... | |
Properties | |
string | EntryPath [get, set] |
Zip entry name for the futures contract More... | |
string | ZipPath [get, set] |
Zip file path for the futures contract collection More... | |
Symbol | Symbol [get] |
Public access to the processor symbol More... | |
Resolution | Resolution [get] |
Accessor for the final enumerator More... | |
TickType | TickType [get, set] |
Type of this futures processor. ASOP's are grouped trade type for file writing. More... | |
Processor for caching and consolidating ticks; then flushing the ticks in memory to disk when triggered.
Definition at line 31 of file AlgoSeekFuturesProcessor.cs.
QuantConnect.ToolBox.AlgoSeekFuturesConverter.AlgoSeekFuturesProcessor.AlgoSeekFuturesProcessor | ( | Symbol | symbol, |
DateTime | date, | ||
TickType | tickType, | ||
Resolution | resolution, | ||
string | dataDirectory | ||
) |
Create a new AlgoSeekFuturesProcessor for enquing consolidated bars and flushing them to disk
symbol | Symbol for the processor |
date | Reference date for the processor |
tickType | TradeBar or QuoteBar to generate |
resolution | Resolution to consolidate |
dataDirectory | Data directory for LEAN |
Definition at line 122 of file AlgoSeekFuturesProcessor.cs.
bool QuantConnect.ToolBox.AlgoSeekFuturesConverter.AlgoSeekFuturesProcessor.ShouldWriteToDisk | ( | ) |
If no data has been consolidated, do not write to disk
Definition at line 109 of file AlgoSeekFuturesProcessor.cs.
void QuantConnect.ToolBox.AlgoSeekFuturesConverter.AlgoSeekFuturesProcessor.Process | ( | Tick | data | ) |
Process the tick; add to the con
data |
Definition at line 188 of file AlgoSeekFuturesProcessor.cs.
void QuantConnect.ToolBox.AlgoSeekFuturesConverter.AlgoSeekFuturesProcessor.FlushBuffer | ( | DateTime | frontierTime, |
bool | finalFlush | ||
) |
Write the in memory queues to the disk.
frontierTime | Current foremost tick time |
finalFlush | Indicates is this is the final push to disk at the end of the data |
Definition at line 203 of file AlgoSeekFuturesProcessor.cs.
|
getset |
Zip entry name for the futures contract
Definition at line 52 of file AlgoSeekFuturesProcessor.cs.
|
getset |
Zip file path for the futures contract collection
Definition at line 68 of file AlgoSeekFuturesProcessor.cs.
|
get |
Public access to the processor symbol
Definition at line 84 of file AlgoSeekFuturesProcessor.cs.
|
get |
Accessor for the final enumerator
Definition at line 92 of file AlgoSeekFuturesProcessor.cs.
|
getset |
Type of this futures processor. ASOP's are grouped trade type for file writing.
Definition at line 101 of file AlgoSeekFuturesProcessor.cs.