8 #ifndef PSYLLID_STREAMING_WRITER_HH_ 9 #define PSYLLID_STREAMING_WRITER_HH_ 15 #include "consumer.hh" 53 public midge::_consumer< midge::type_list< time_data > >,
77 virtual void execute( midge::diptera* a_midge =
nullptr );
96 virtual void do_apply_config(
streaming_writer* a_node,
const scarab::param_node& a_config )
const;
97 virtual void do_dump_config(
const streaming_writer* a_node, scarab::param_node& a_config )
const;
std::shared_ptr< header_wrapper > header_wrap_ptr
Base class for all writers.
virtual void initialize()
virtual ~streaming_writer()
virtual void execute(midge::diptera *a_midge=nullptr)
std::shared_ptr< monarch_wrapper > monarch_wrap_ptr
A consumer to that writes all time ROACH packets to an egg file.
mv_accessible(unsigned, file_num)
monarch_wrap_ptr f_monarch_ptr
virtual void prepare_to_write(monarch_wrap_ptr a_mw_ptr, header_wrap_ptr a_hw_ptr)
unsigned f_last_pkt_in_batch