|
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.