apollo::data::RecordProcessor Class Reference

Process messages and apply the rules based on configured triggers. More...

#include <record_processor.h>

Inheritance diagram for apollo::data::RecordProcessor:

Collaboration diagram for apollo::data::RecordProcessor:

Public Member Functions
	RecordProcessor (const std::string &source_record_dir, const std::string &restored_output_dir)
virtual bool	Init (const SmartRecordTrigger &trigger_conf)
virtual bool	Process ()=0
virtual std::string	GetDefaultOutputFile () const =0
virtual	~RecordProcessor ()

Protected Member Functions
bool	InitTriggers (const SmartRecordTrigger &trigger_conf)
bool	ShouldRestore (const cyber::record::RecordMessage &msg) const

Protected Attributes
const std::string	source_record_dir_
const std::string	restored_output_dir_
std::vector< std::unique_ptr< TriggerBase > >	triggers_
std::unique_ptr< cyber::record::RecordWriter >	writer_ = nullptr

Detailed Description

Process messages and apply the rules based on configured triggers.

Constructor & Destructor Documentation

RecordProcessor()

apollo::data::RecordProcessor::RecordProcessor	(	const std::string &	source_record_dir,
		const std::string &	restored_output_dir
	)

~RecordProcessor()

virtual apollo::data::RecordProcessor::~RecordProcessor ( )

inlinevirtual

Member Function Documentation

GetDefaultOutputFile()

virtual std::string apollo::data::RecordProcessor::GetDefaultOutputFile ( ) const

pure virtual

Implemented in apollo::data::RealtimeRecordProcessor, and apollo::data::PostRecordProcessor.

Init()

virtual bool apollo::data::RecordProcessor::Init ( const SmartRecordTrigger &  trigger_conf )

virtual

Reimplemented in apollo::data::RealtimeRecordProcessor, and apollo::data::PostRecordProcessor.

InitTriggers()

bool apollo::data::RecordProcessor::InitTriggers ( const SmartRecordTrigger &  trigger_conf )

protected

Process()

virtual bool apollo::data::RecordProcessor::Process ( )

pure virtual

Implemented in apollo::data::RealtimeRecordProcessor, and apollo::data::PostRecordProcessor.

ShouldRestore()

bool apollo::data::RecordProcessor::ShouldRestore ( const cyber::record::RecordMessage &  msg ) const

protected

Member Data Documentation

restored_output_dir_

const std::string apollo::data::RecordProcessor::restored_output_dir_

protected

source_record_dir_

const std::string apollo::data::RecordProcessor::source_record_dir_

protected

triggers_

std::vector<std::unique_ptr<TriggerBase> > apollo::data::RecordProcessor::triggers_

protected

writer_

std::unique_ptr<cyber::record::RecordWriter> apollo::data::RecordProcessor::writer_ = nullptr

protected

---

The documentation for this class was generated from the following file:

• modules/data/tools/smart_recorder/record_processor.h