Type Members

1.  class GrpcMediatorAdministrationService extends MediatorAdministrationService with GrpcPruningScheduler with HasPruningScheduler with NamedLogging
2.  class GrpcMediatorInitializationService extends MediatorInitializationService with NamedLogging

   Hosts the initialization service for the mediator.

   Hosts the initialization service for the mediator. Upon receiving an initialize request it will the provided initialize function.

3.  class GrpcMediatorInspectionService extends MediatorInspectionService with NamedLogging

   The mediator inspection service delivers a stream of finalized verdicts.

   The mediator inspection service delivers a stream of finalized verdicts. The verdicts are sorted by the finalization time, which additionally is capped by the watermark tracked via the provided time awaiter. In case the watermark is reached and no new verdicts are found, the stream waits to be notified by the time awaiter when new watermarks are encountered. In practice, the time awaiter follows the observed sequencing.

   Notice:While returning the results in order of the request time would be a more natural way to consume the information, this would add significant complexity to the implementation, because of various reasons:

   • a later request could be completed sooner than an earlier requests
   • the inspection service would have to interact with the ongoing mediator state to understand which requests are still pending and not emit verdicts of requests after the oldest pending request

   In contrast, using the finalization time for sorting the verdicts is a simple and stable way to deliver all known verdicts purely based on the verdicts persisted in the finalized response store.

4.  class GrpcMediatorStatusService extends MediatorStatusService with NamedLogging