42 typedef std::vector<std::string>
FileList;
70 #if !defined(ONIXS_CMEMDH_NO_DEPRECATED) 82 #endif // !ONIXS_CMEMDH_NO_DEPRECATED 126 : begin_(other.begin_)
134 return (begin_ >= end_);
141 return (begin_ <= timestamp && timestamp < end_);
171 begin_ = other.begin_;
203 template <
class DataSource,
class DataSourceLess = std::less<DataSource> >
208 typedef std::map<DataSource, DataSource, DataSourceLess>
Aliases;
221 : settingsUse_(other.settingsUse_)
222 , aliases_(other.aliases_)
223 , timeSpan_(other.timeSpan_)
224 , speed_(other.speed_)
237 settingsUse_ = policy;
287 settingsUse_ = other.settingsUse_;
289 aliases_ = other.aliases_;
291 timeSpan_ = other.timeSpan_;
293 speed_ = other.speed_;
322 settingsUse(HandlerSettingsUse::AsIs);
329 return HandlerSettingsUse::AsIs;
337 using Base::settingsUse;
354 settingsUse(HandlerSettingsUse::AsIs);
361 return HandlerSettingsUse::AsIs;
369 using Base::settingsUse;
388 Handler* handlers[] = {&handler};
404 Handler* handlers[] = {&handler};
430 Handler* handlers[] = {&handler};
468 Handler* handlers[] = {&handler};
470 replayPcapFiles(snapshots, snapshotsApplyOptions, incrementals, handlers, 1, supplements);
477 Handler* handlers[] = {&handler};
498 Handler* handlers[] = {&handler};
Defines range of log entries to be replayed.
ReplaySpan(const ReplaySpan &other)
Initializes the instance as a copy of the other one.
Handler settings aren't touched and used as they are during the replay.
Replay supplements for the CME DataMine historical data replay functionality.
Replay supplements for the PCAP replay functionality.
std::vector< std::string > FileList
Ordered list of logs to be replayed.
Encapsulates all the machinery related with market data processing from CME Market Data Platform...
DatamineReplaySettings()
Initializes settings with the default values.
UInt32 ChannelId
Identifies CME channel.
void settingsUse(HandlerSettingsUse::Enum policy)
Defines handler settings use policy.
ReplaySpan()
Initializes empty span.
void gatherPcapFiles(FileList &files, const std::string &location, const std::string &ext)
Gathers files which are stored in the given folder with the given extension.
Represents time point without time-zone information.
ReplaySettings< NetFeedId > LogReplaySettings
Replay supplements for log replay functionality.
const Aliases & aliases() const
Aliases to be used during the replay.
Timestamp timestamp(const MultiContainer &, Tag)
Retrieves last update time field value.
PcapReplaySettings()
Initializes settings with the default values.
#define ONIXS_CMEMDH_EXPORTED_CLASS_DECL(typeName)
#define ONIXS_CMEMDH_LTWT
const ReplaySpan & timeSpan() const
Time span for which entries are to be processed.
Various supplemental settings affecting the way the logged data is replayed.
std::map< DataSource, DataSource, DataSourceLess > Aliases
The table of data source aliases.
void replayLogFiles(const FileList &logs, Handler &handler, const UseHandlerSettingsAsIs &marker)
Processes market data stored in the log files according to specified settings.
void replayDatamineFiles(const FileList &logs, Handler &handler)
Replays the given list of historical data for the given Handler according to the default settings...
bool value(Number &number, const MultiContainer &container, Tag tag)
Finds a tag-value entry in the given collection by the given tag and returns its value component tran...
bool empty() const
Indicates whether span is empty or not.
Defines whether processing and other settings must be extracted from logs and used during the replay...
DatamineReplaySettings::Aliases ChannelIdAliases
Collection of channels to be used by the CME Datamine historical file replay to replace captured sour...
#define ONIXS_CMEMDH_NAMESPACE_BEGIN
void begin(const Timestamp &value)
Updates the beginning of the range.
A Marker instructing the log replay procedure to use Handler settings as they are without applying an...
ReplaySpan & timeSpan()
Time span for which entries are to be processed.
HandlerSettingsUse::Enum settingsUse() const
Settings aren't stored in Datamine thus constant value is returned.
#define ONIXS_CMEMDH_EXPORTED
void speed(ReplaySpeed::Enum policy)
Defines processing speed.
HandlerSettingsUse::Enum settingsUse() const
Handler settings use policy.
const Timestamp & end() const
Indicates the end of the range.
ReplaySpeed::Enum speed() const
Indicates processing speed policy.
Controls speed of market data replay.
ReplaySettings & operator=(const ReplaySettings &other)
Re-initializes as a copy of the other one.
Aliases & aliases()
Aliases to be used during the replay.
LogReplaySettings::Aliases FeedIdAliases
Collection of logged data sources (feed identifiers) to be used by the Log Replay to replace logged s...
const Timestamp & begin() const
Indicates the beginning of the range.
HandlerSettingsUse::Enum settingsUse() const
Settings aren't stored in PCAPs thus constant value is returned.
PcapReplaySettings::Aliases NetAddressAliases
Collection of data sources (feed identifiers) to be used by the PCAP file replay to replace captured ...
ReplaySettings(const ReplaySettings &other)
Initializes as a copy of the other one.
ReplaySettings()
Initializes the settings with the default values.
Enum
Controls speed of market data replay.
void gatherFiles(FileList &, const std::string &, const std::string &)
Gathers files which are stored in the given folder with the given extension.
bool contain(const Timestamp ×tamp) const
Indicates whether the given timestamp belongs to the given time span.
ReplaySpan(const Timestamp &begin, const Timestamp &end)
Initializes the instance according to the given bounds.
ReplaySpan & operator=(const ReplaySpan &other)
Re-initializes as a copy of the other one.
void end(const Timestamp &value)
Indicates the end of the range.
void gatherLogFiles(FileList &, ChannelId, const std::string &, const std::string &)
Gathers log files logs which are available for given channel and are stored in a given folder...
void replayPcapFiles(const FileList &logs, Handler &handler)
Replays the given list of PCAP files for the given Handler according to the default settings...
#define ONIXS_CMEMDH_NAMESPACE_END