2 Commits

Author	SHA1	Message	Date
Fedor Sakharov	fc45a8e673	Adds start and stop work heartbeats. (#1188) ... * Adds start and stop work heartbeats. * Apply suggestions from code review Co-authored-by: Bastian Köcher <bkchr@users.noreply.github.com> * Fix code after suggested changes * Finalizing stops work on earlier lower blocks. * Fix func parameter and flaky test Co-authored-by: Bastian Köcher <bkchr@users.noreply.github.com>	2020-06-03 09:30:21 +03:00
Fedor Sakharov	fa46a92353	Overseer (#1152) ... * Initial commit * Licenses, spaces, docs * Add a spawner * Watch spawned subsystems with a FuturesUnordered * Move the types around a bit * Suggested fixes by Max * Add a handler to talk to the Overseer * FromOverseer and ToOverseer msgs and stopping * Docs and return errors * Dont broadcast, have add a from field to messages * Allow communication between subsystems and outside world * A message with a oneshot to send result example * Remove leftover can_recv_msg * Remove from field from messages * Dont be generic over stuff * Gather messages with StreamUnordered * Fix comments and formatting * More docs fixes and an example * Apply suggestions from code review Co-authored-by: Robert Habermeier <rphmeier@gmail.com> * Fixes from review Move function from impl block. Do not panic but resolve with errors if spawner fails or subsystem resolves. * Dropping a handler results in a flaky test Co-authored-by: Robert Habermeier <rphmeier@gmail.com>	2020-06-02 15:36:20 +03:00