kcenon::thread::dag_job Member List

This is the complete list of members for kcenon::thread::dag_job, including all inherited members.

add_dependencies(const std::vector< job_id > &dependency_ids) -> void	kcenon::thread::dag_job	inline
add_dependency(job_id dependency_id) -> void	kcenon::thread::dag_job	inline
cancellation_token_	kcenon::thread::job	protected
components_	kcenon::thread::job	private
dag_id_	kcenon::thread::dag_job	private
dag_job(const std::string &name="dag_job")	kcenon::thread::dag_job	explicit
data_	kcenon::thread::job	protected
dependencies_	kcenon::thread::dag_job	private
do_work() -> common::VoidResult override	kcenon::thread::dag_job	virtual
end_time_	kcenon::thread::dag_job	private
enqueue_time_	kcenon::thread::job	private
ensure_components() -> job_components &	kcenon::thread::job	private
error_message_	kcenon::thread::dag_job	private
fallback_func_	kcenon::thread::dag_job	private
get_cancellation_token() const -> cancellation_token	kcenon::thread::job	virtual
get_dag_id() const -> job_id	kcenon::thread::dag_job	inline
get_dependencies() const -> const std::vector< job_id > &	kcenon::thread::dag_job	inline
get_end_time() const -> std::chrono::steady_clock::time_point	kcenon::thread::dag_job	inline
get_enqueue_time() const -> std::chrono::steady_clock::time_point	kcenon::thread::job	inline
get_error_message() const -> const std::optional< std::string > &	kcenon::thread::dag_job	inline
get_fallback() const -> const std::function< common::VoidResult()> &	kcenon::thread::dag_job	inline
get_info() const -> dag_job_info	kcenon::thread::dag_job
get_job_id() const -> std::uint64_t	kcenon::thread::job	inline
get_job_queue(void) const -> std::shared_ptr< job_queue >	kcenon::thread::job	virtual
get_name(void) const -> std::string	kcenon::thread::job
get_priority() const -> job_priority	kcenon::thread::job
get_result() const -> const T &	kcenon::thread::dag_job	inline
get_result_any() const -> const std::any &	kcenon::thread::dag_job	inline
get_retry_policy() const -> std::optional< retry_policy >	kcenon::thread::job
get_start_time() const -> std::chrono::steady_clock::time_point	kcenon::thread::dag_job	inline
get_state() const -> dag_job_state	kcenon::thread::dag_job	inline
get_submit_time() const -> std::chrono::steady_clock::time_point	kcenon::thread::dag_job	inline
get_timeout() const -> std::optional< std::chrono::milliseconds >	kcenon::thread::job
has_components() const -> bool	kcenon::thread::job
has_explicit_cancellation() const -> bool	kcenon::thread::job
has_fallback() const -> bool	kcenon::thread::dag_job	inline
has_result() const -> bool	kcenon::thread::dag_job	inline
invoke_callbacks(const common::VoidResult &result) -> void	kcenon::thread::job	protected
job(const std::string &name="job")	kcenon::thread::job
job(const std::vector< uint8_t > &data, const std::string &name="data_job")	kcenon::thread::job
job_id_	kcenon::thread::job	private
job_queue_	kcenon::thread::job	protected
name_	kcenon::thread::job	protected
next_dag_id_	kcenon::thread::dag_job	privatestatic
next_job_id_	kcenon::thread::job	privatestatic
record_end_time() -> void	kcenon::thread::dag_job	inline
record_start_time() -> void	kcenon::thread::dag_job	inline
result_	kcenon::thread::dag_job	private
set_cancellation_token(const cancellation_token &token) -> void	kcenon::thread::job	virtual
set_error_message(const std::string &message) -> void	kcenon::thread::dag_job	inline
set_fallback(std::function< common::VoidResult()> fallback_func) -> void	kcenon::thread::dag_job	inline
set_job_queue(const std::shared_ptr< job_queue > &job_queue) -> void	kcenon::thread::job	virtual
set_result(T &&value) -> void	kcenon::thread::dag_job	inline
set_state(dag_job_state new_state) -> void	kcenon::thread::dag_job	inline
set_work(std::function< common::VoidResult()> work_func) -> void	kcenon::thread::dag_job	inline
set_work_with_result(std::function< common::Result< T >()> work_func) -> void	kcenon::thread::dag_job	inline
start_time_	kcenon::thread::dag_job	private
state_	kcenon::thread::dag_job	private
submit_time_	kcenon::thread::dag_job	private
to_string() const -> std::string override	kcenon::thread::dag_job	virtual
try_transition_state(dag_job_state expected, dag_job_state desired) -> bool	kcenon::thread::dag_job	inline
with_cancellation(const cancellation_token &token) -> job &	kcenon::thread::job
with_on_complete(std::function< void(common::VoidResult)> callback) -> job &	kcenon::thread::job
with_on_error(std::function< void(const common::error_info &)> callback) -> job &	kcenon::thread::job
with_priority(job_priority priority) -> job &	kcenon::thread::job
with_retry(const retry_policy &policy) -> job &	kcenon::thread::job
with_timeout(std::chrono::milliseconds timeout) -> job &	kcenon::thread::job
work_func_	kcenon::thread::dag_job	private
~dag_job() override	kcenon::thread::dag_job
~job(void)	kcenon::thread::job	virtual