joque
task orchestration library
joque::exec_visitor Class Reference

Execution visitor interface, used by execution. More...

#include <exec_visitor.hpp>

+ Inheritance diagram for joque::exec_visitor:

Public Member Functions

virtual void after_node_enque (const dag_node &)
 Run after node is enqued. More...
 
virtual void on_detected_cycle (std::span< const dag_node * >)
 Ran in case cycle is detected. More...
 
virtual void after_job_is_inval (const dag_node &, std::string_view)
 Run after check whenever job was invalidated. More...
 
virtual void after_dep_inval (const dag_node &, const dag_node &)
 Run after node became invalidated because of other node. More...
 
virtual void before_run (const exec_record &, const dag_node &)
 Executed once execution starts for the node. More...
 
virtual void on_run_log (const dag_node &, std::string_view)
 Run after job finished execution. More...
 
virtual void after_run (const exec_record &, const run_record *, const dag_node &)
 Executed after execution of node. More...
 
virtual void on_tick (const exec_record &)
 
virtual void after_execution (const exec_record &)
 Run after execution finished. More...
 
virtual ~exec_visitor ()=default
 

Detailed Description

Execution visitor interface, used by execution.

Member functions are called on events that occur during execution of tasks.

Constructor & Destructor Documentation

◆ ~exec_visitor()

virtual joque::exec_visitor::~exec_visitor ( )
virtualdefault

Member Function Documentation

◆ after_node_enque()

virtual void joque::exec_visitor::after_node_enque ( const dag_node )
inlinevirtual

Run after node is enqued.

Reimplemented in joque::print_exec_visitor.

◆ on_detected_cycle()

virtual void joque::exec_visitor::on_detected_cycle ( std::span< const dag_node * >  )
inlinevirtual

Ran in case cycle is detected.

Reimplemented in joque::print_exec_visitor.

◆ after_job_is_inval()

virtual void joque::exec_visitor::after_job_is_inval ( const dag_node ,
std::string_view   
)
inlinevirtual

Run after check whenever job was invalidated.

Reimplemented in joque::print_exec_visitor.

◆ after_dep_inval()

virtual void joque::exec_visitor::after_dep_inval ( const dag_node ,
const dag_node  
)
inlinevirtual

Run after node became invalidated because of other node.

Reimplemented in joque::print_exec_visitor.

◆ before_run()

virtual void joque::exec_visitor::before_run ( const exec_record ,
const dag_node  
)
inlinevirtual

Executed once execution starts for the node.

Reimplemented in joque::print_exec_visitor.

◆ on_run_log()

virtual void joque::exec_visitor::on_run_log ( const dag_node ,
std::string_view   
)
inlinevirtual

Run after job finished execution.

Reimplemented in joque::print_exec_visitor.

◆ after_run()

virtual void joque::exec_visitor::after_run ( const exec_record ,
const run_record ,
const dag_node  
)
inlinevirtual

Executed after execution of node.

Parameters
recIf run produces a run record, it is passed, nullptr on errors

Reimplemented in joque::print_exec_visitor.

◆ on_tick()

virtual void joque::exec_visitor::on_tick ( const exec_record )
inlinevirtual

Reimplemented in joque::print_exec_visitor.

◆ after_execution()

virtual void joque::exec_visitor::after_execution ( const exec_record )
inlinevirtual

Run after execution finished.

Reimplemented in joque::print_exec_visitor.


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