VLink  2.0.0
A high-performance communication middleware
vlink::BagWriter Member List

This is the complete list of members for vlink::BagWriter, including all inherited members.

async_run()vlink::MessageLoop
BagWriter(const std::string &path, const Config &config={})vlink::BagWriterexplicit
bind_plugin_interface(const std::shared_ptr< BagPluginInterface > &plugin_interface)vlink::BagWritervirtual
Callback typedefvlink::MessageLoop
clear() noexceptvlink::BagWriter
clear_plugin_interface()vlink::BagWritervirtual
CompressType enum namevlink::BagWriter
convert_action(ActionType type)vlink::BagWriterprotectedstatic
convert_recorded_url(const std::string &url) constvlink::BagWriterprotected
create(const std::string &path, const Config &config={})vlink::BagWriterstatic
detach_plugin()vlink::BagWriterprotected
exec_task(const Schedule::Config &config, CallbackT &&callback)vlink::MessageLoop
exec_task(const Schedule::Config &config, CallbackT &&callback)vlink::MessageLoop
fail() const noexceptvlink::BagWriter
filter_get(const std::string &path)vlink::BagWriterstatic
flush_plugin()vlink::BagWriterprotected
get_alive_state() constvlink::MessageLoop
get_default_app_name()vlink::BagWriterprotectedstatic
get_default_tag_name()vlink::BagWriterprotectedstatic
get_default_timezone_diff()vlink::BagWriterprotectedstatic
get_format_date(SystemClock *current=nullptr, bool file_format=false)vlink::BagWriterprotectedstatic
get_max_elapsed_time() constvlink::MessageLoopvirtual
get_max_task_count() constvlink::MessageLoopvirtual
get_max_timer_count() constvlink::MessageLoopvirtual
get_name() constvlink::MessageLoop
get_record_timestamp() const =0vlink::BagWriterprotectedpure virtual
get_schema_interface()vlink::BagWriterprotectedstatic
get_split_index() const =0vlink::BagWriterpure virtual
get_strategy() constvlink::MessageLoop
get_task_count() constvlink::MessageLoop
get_type() constvlink::MessageLoop
get_url_meta(const std::string &url, const std::string &ser, int &url_index, int &ser_index) constvlink::BagWriterprotected
get_url_meta(int url_index, int ser_index, std::string &url, std::string &ser) constvlink::BagWriterprotected
global_get()vlink::BagWriterstatic
invoke_task(FunctionT &&function, ArgsT &&... args)vlink::MessageLoopinline
invoke_task_with_priority(FunctionT &&function, uint16_t priority, ArgsT &&... args)vlink::MessageLoopinline
is_busy() constvlink::MessageLoop
is_dumping() const =0vlink::BagWriterpure virtual
is_in_same_thread() constvlink::MessageLoopvirtual
is_ready_to_quit() constvlink::MessageLoop
is_running() constvlink::MessageLoop
is_split_mode() const =0vlink::BagWriterpure virtual
kBlockStrategy enum valuevlink::MessageLoop
kCompressAuto enum valuevlink::BagWriter
kCompressLz4 enum valuevlink::BagWriter
kCompressLzav enum valuevlink::BagWriter
kCompressNone enum valuevlink::BagWriter
kCompressZstd enum valuevlink::BagWriter
kHighestPriority enum valuevlink::MessageLoop
kLockfreeType enum valuevlink::MessageLoop
kLowestPriority enum valuevlink::MessageLoop
kNoPriority enum valuevlink::MessageLoop
kNormalPriority enum valuevlink::MessageLoop
kNormalType enum valuevlink::MessageLoop
kOptimizationStrategy enum valuevlink::MessageLoop
kPopStrategy enum valuevlink::MessageLoop
kPriorityType enum valuevlink::MessageLoop
kTimerPriority enum valuevlink::MessageLoop
MessageLoop()vlink::MessageLoop
MessageLoop(Type type)vlink::MessageLoopexplicit
on_begin()vlink::MessageLoopprotectedvirtual
on_end()vlink::MessageLoopprotectedvirtual
on_idle()vlink::MessageLoopprotectedvirtual
on_task_changed(Callback &&callback, uint32_t start_time)vlink::MessageLoopprotectedvirtual
on_task_timeout(Callback &&callback, uint32_t elapsed_time)vlink::MessageLoopprotectedvirtual
operator bool() const noexceptvlink::BagWriterexplicit
operator<<(const Frame &frame)vlink::BagWriter
operator<<(const SchemaData &schema_data)vlink::BagWriter
post_task(Callback &&callback)vlink::MessageLoop
post_task_handle(Callback &&callback, const PostTaskOptions &options={})vlink::MessageLoop
post_task_with_priority(Callback &&callback, uint16_t priority)vlink::MessageLoop
post_task_with_priority_handle(Callback &&callback, uint16_t priority, const PostTaskOptions &options={})vlink::MessageLoop
Priority enum namevlink::MessageLoop
push(const Frame &frame, bool immediate=false)vlink::BagWriter
push_schema(const SchemaData &schema_data, bool immediate=false)=0vlink::BagWriterpure virtual
quit(bool force=false)vlink::MessageLoop
record(const Frame &frame, bool immediate)=0vlink::BagWriterprotectedpure virtual
recorded_urls_for_origin(const std::string &url) constvlink::BagWriterprotected
recover_recorded_url(const std::string &url) constvlink::BagWriterprotected
register_begin_handler(Callback &&callback)vlink::MessageLoop
register_end_handler(Callback &&callback)vlink::MessageLoop
register_idle_handler(Callback &&callback)vlink::MessageLoop
register_schema_callback(SchemaCallback &&callback)=0vlink::BagWriterpure virtual
register_split_callback(SplitCallback &&callback, bool before)=0vlink::BagWriterpure virtual
reset_lockfree_capacity()vlink::MessageLoop
run()vlink::MessageLoop
sample_mutex()vlink::BagWriterprotected
SchemaCallback typedefvlink::BagWriter
set_name(const std::string &name)vlink::MessageLoop
set_strategy(Strategy strategy)vlink::MessageLoop
set_url_loss(const std::string &url, double loss)vlink::BagWritervirtual
spin()vlink::MessageLoop
spin_once(bool block=true)vlink::MessageLoop
SplitCallback typedefvlink::BagWriter
Strategy enum namevlink::MessageLoop
SystemClock typedefvlink::BagWriter
total_url_loss_map_ref()vlink::BagWriterprotected
Type enum namevlink::MessageLoop
url_loss_map_ref()vlink::BagWriterprotected
wait_for_idle(int ms=Timer::kInfinite, bool check=true)vlink::MessageLoopvirtual
wait_for_quit(int ms=Timer::kInfinite, bool check=true)vlink::MessageLoop
wakeup()vlink::MessageLoop
~BagWriter()vlink::BagWritervirtual
~MessageLoop()vlink::MessageLoopvirtual