VLink 2.0.0
A high-performance communication middleware
Loading...
Searching...
No Matches
vlink::BagReader Member List

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

async_run()vlink::MessageLoop
BagReader(const std::string &path, bool read_only=true, bool try_to_fix=false)vlink::BagReaderexplicit
bind_plugin_interface(const std::shared_ptr< BagReaderPluginInterface > &plugin_interface)vlink::BagReadervirtual
Callback typedefvlink::MessageLoop
check()=0vlink::BagReaderpure virtual
convert_action(std::string_view str)vlink::BagReaderprotectedstatic
create(const std::string &path, bool read_only=true, bool try_to_fix=false)vlink::BagReaderstatic
detect_schema()=0vlink::BagReaderpure virtual
exec_task(const Schedule::Config &config, CallbackT &&callback)vlink::MessageLoop
exec_task(const Schedule::Config &config, CallbackT &&callback)vlink::MessageLoop
FinishCallback typedefvlink::BagReader
fix(bool rebuild=false)=0vlink::BagReaderpure virtual
get_info() const =0vlink::BagReaderpure virtual
get_max_elapsed_time() constvlink::MessageLoopvirtual
get_max_task_count() constvlink::MessageLoopvirtual
get_max_timer_count() constvlink::MessageLoopvirtual
get_name() constvlink::MessageLoop
get_real_timestamp() const =0vlink::BagReaderpure virtual
get_schema_type(const std::string &url) const =0vlink::BagReaderpure virtual
get_ser_type(const std::string &url) const =0vlink::BagReaderpure virtual
get_split_index() const =0vlink::BagReaderpure virtual
get_status() const =0vlink::BagReaderpure virtual
get_strategy() constvlink::MessageLoop
get_task_count() constvlink::MessageLoop
get_timestamp() const =0vlink::BagReaderpure virtual
get_type() constvlink::MessageLoop
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_in_same_thread() constvlink::MessageLoopvirtual
is_jumping() const =0vlink::BagReaderpure virtual
is_ready_to_quit() constvlink::MessageLoop
is_running() constvlink::MessageLoop
is_split_mode() const =0vlink::BagReaderpure virtual
jump(int64_t begin_time, double rate, int times, bool force_to_play=false)=0vlink::BagReaderpure virtual
kBlockStrategy enum valuevlink::MessageLoop
kHighestPriority enum valuevlink::MessageLoop
kInfinitevlink::BagReaderstatic
kLockfreeType enum valuevlink::MessageLoop
kLowestPriority enum valuevlink::MessageLoop
kNoPriority enum valuevlink::MessageLoop
kNormalPriority enum valuevlink::MessageLoop
kNormalType enum valuevlink::MessageLoop
kOptimizationStrategy enum valuevlink::MessageLoop
kPaused enum valuevlink::BagReader
kPlaying enum valuevlink::BagReader
kPopStrategy enum valuevlink::MessageLoop
kPriorityType enum valuevlink::MessageLoop
kStoped enum valuevlink::BagReader
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
OutputCallback typedefvlink::BagReader
pause()=0vlink::BagReaderpure virtual
pause_to_next()=0vlink::BagReaderpure virtual
play(const Config &config)=0vlink::BagReaderpure virtual
post_task(Callback &&callback)vlink::MessageLoop
post_task_with_priority(Callback &&callback, uint16_t priority)vlink::MessageLoop
Priority enum namevlink::MessageLoop
process_output(int64_t timestamp, const std::string &url, ActionType action_type, const Bytes &data)vlink::BagReaderprotected
process_url_metas(std::vector< Info::UrlMeta > &url_metas)vlink::BagReaderprotected
quit(bool force=false)vlink::MessageLoop
ReadyCallback typedefvlink::BagReader
rebuild_url_meta_maps(const std::vector< Info::UrlMeta > &url_metas, std::unordered_map< std::string, std::string > &ser_map, std::unordered_map< std::string, SchemaType > &schema_type_map)vlink::BagReaderprotectedstatic
register_begin_handler(Callback &&callback)vlink::MessageLoop
register_end_handler(Callback &&callback)vlink::MessageLoop
register_finish_callback(FinishCallback &&finish_callback)vlink::BagReadervirtual
register_idle_handler(Callback &&callback)vlink::MessageLoop
register_output_callback(OutputCallback &&output_callback)vlink::BagReadervirtual
register_ready_callback(ReadyCallback &&ready_callback)vlink::BagReadervirtual
register_status_callback(StatusCallback &&status_callback)vlink::BagReadervirtual
reindex()=0vlink::BagReaderpure virtual
reset_lockfree_capacity()vlink::MessageLoop
resume()=0vlink::BagReaderpure virtual
run()vlink::MessageLoop
set_name(const std::string &name)vlink::MessageLoop
set_strategy(Strategy strategy)vlink::MessageLoop
spin()vlink::MessageLoop
spin_once(bool block=true)vlink::MessageLoop
Status enum namevlink::BagReader
StatusCallback typedefvlink::BagReader
stop()=0vlink::BagReaderpure virtual
Strategy enum namevlink::MessageLoop
tag(const std::string &tag_name)=0vlink::BagReaderpure virtual
Type enum namevlink::MessageLoop
wait_for_idle(int ms=Timer::kInfinite, bool check=true)vlink::MessageLoop
wait_for_quit(int ms=Timer::kInfinite, bool check=true)vlink::MessageLoop
wakeup()vlink::MessageLoop
~BagReader()vlink::BagReadervirtual
~MessageLoop()vlink::MessageLoopvirtual