ark::supervisor::Supervisor

Defined in header “ark/supervisor/supervisor.hh”.

Methods

  • Supervisor(SupervisorConfig config)

  • ~Supervisor()

  • std::vector< SupervisedProcessStatus > poll(std::chrono::nanoseconds duration)
    Poll the processes and return their state.

  • void start_process(const std::string & name, const ProcessConfigurationOverrides & overrides)
    Start the given process. This is used to start on demand processes. If the process is already running it will do nothing.

  • void stop()
    Stop the current supervised set. This will maintain any internal state so the set can be restarted with restart.

  • void register_heartbeat(const std::string & name)
    Registers a heartbeat for the process with the given name.

  • std::pair< uint64_t, std::string > process_console_output(const std::string & name, uint64_t requested_start_offset)
    Returns as much console output for the given process as possible. Returns a pair, the output, and the offset into the console output of that output.

    You can call with a start offset to support ‘pagniation’ of data.