Trait orchestra::Subsystem

pub trait Subsystem<Ctx, E>where
    Ctx: SubsystemContext,
    E: Error + Send + Sync + 'static + From<OrchestraError>,{
    fn start(self, ctx: Ctx) -> SpawnedSubsystem<E>;
}

A trait that describes the Subsystems that can run on the Orchestra.

It is generic over the message type circulating in the system. The idea that we want some type containing persistent state that can spawn actually running subsystems when asked.

Required Methods

fn start(self, ctx: Ctx) -> SpawnedSubsystem<E>

Start this Subsystem and return SpawnedSubsystem.

Implementors

impl<Context> Subsystem<Context, SubsystemError> for ApprovalDistributionwhere
    Context: ApprovalDistributionContextTrait + SubsystemContext,
    <Context as ApprovalDistributionContextTrait>::Sender: ApprovalDistributionSenderTrait,
    <Context as SubsystemContext>::Sender: ApprovalDistributionSenderTrait,

impl<Context> Subsystem<Context, SubsystemError> for BitfieldDistributionwhere
    Context: BitfieldDistributionContextTrait + SubsystemContext,
    <Context as BitfieldDistributionContextTrait>::Sender: BitfieldDistributionSenderTrait,
    <Context as SubsystemContext>::Sender: BitfieldDistributionSenderTrait,

impl<Context> Subsystem<Context, SubsystemError> for AvailabilityDistributionSubsystemwhere
    Context: AvailabilityDistributionContextTrait + SubsystemContext,
    <Context as AvailabilityDistributionContextTrait>::Sender: AvailabilityDistributionSenderTrait,
    <Context as SubsystemContext>::Sender: AvailabilityDistributionSenderTrait,

impl<Context> Subsystem<Context, SubsystemError> for AvailabilityRecoverySubsystemwhere
    Context: AvailabilityRecoveryContextTrait + SubsystemContext,
    <Context as AvailabilityRecoveryContextTrait>::Sender: AvailabilityRecoverySenderTrait,
    <Context as SubsystemContext>::Sender: AvailabilityRecoverySenderTrait,

impl<Context> Subsystem<Context, SubsystemError> for CollatorProtocolSubsystemwhere
    Context: CollatorProtocolContextTrait + SubsystemContext,
    <Context as CollatorProtocolContextTrait>::Sender: CollatorProtocolSenderTrait,
    <Context as SubsystemContext>::Sender: CollatorProtocolSenderTrait,

impl<Context, AD> Subsystem<Context, SubsystemError> for DisputeDistributionSubsystem<AD>where
    <Context as DisputeDistributionContextTrait>::Sender: DisputeDistributionSenderTrait + Sync + Send,
    AD: AuthorityDiscovery + Clone,
    Context: DisputeDistributionContextTrait + SubsystemContext,
    <Context as DisputeDistributionContextTrait>::Sender: DisputeDistributionSenderTrait,
    <Context as SubsystemContext>::Sender: DisputeDistributionSenderTrait,

impl<Context, AD> Subsystem<Context, SubsystemError> for GossipSupport<AD>where
    AD: AuthorityDiscovery + Clone,
    Context: GossipSupportContextTrait + SubsystemContext,
    <Context as GossipSupportContextTrait>::Sender: GossipSupportSenderTrait,
    <Context as SubsystemContext>::Sender: GossipSupportSenderTrait,

impl<Net, AD, Context> Subsystem<Context, SubsystemError> for NetworkBridgeTx<Net, AD>where
    Net: Network + Sync,
    AD: AuthorityDiscovery + Clone + Sync,
    Context: NetworkBridgeTxContextTrait + SubsystemContext,
    <Context as NetworkBridgeTxContextTrait>::Sender: NetworkBridgeTxSenderTrait,
    <Context as SubsystemContext>::Sender: NetworkBridgeTxSenderTrait,

impl<Net, AD, Context> Subsystem<Context, SubsystemError> for NetworkBridgeRx<Net, AD>where
    Net: Network + Sync,
    AD: AuthorityDiscovery + Clone + Sync,
    Context: NetworkBridgeRxContextTrait + SubsystemContext,
    <Context as NetworkBridgeRxContextTrait>::Sender: NetworkBridgeRxSenderTrait,
    <Context as SubsystemContext>::Sender: NetworkBridgeRxSenderTrait,

impl<Context> Subsystem<Context, SubsystemError> for CollationGenerationSubsystemwhere
    Context: CollationGenerationContextTrait + SubsystemContext,
    <Context as CollationGenerationContextTrait>::Sender: CollationGenerationSenderTrait,
    <Context as SubsystemContext>::Sender: CollationGenerationSenderTrait,

impl<Context> Subsystem<Context, SubsystemError> for ApprovalVotingSubsystemwhere
    Context: ApprovalVotingContextTrait + SubsystemContext + Send,
    <Context as ApprovalVotingContextTrait>::Sender: ApprovalVotingSenderTrait,
    <Context as SubsystemContext>::Sender: ApprovalVotingSenderTrait,

impl<Context> Subsystem<Context, SubsystemError> for AvailabilityStoreSubsystemwhere
    Context: AvailabilityStoreContextTrait + SubsystemContext,
    <Context as AvailabilityStoreContextTrait>::Sender: AvailabilityStoreSenderTrait,
    <Context as SubsystemContext>::Sender: AvailabilityStoreSenderTrait,

impl<Context> Subsystem<Context, SubsystemError> for CandidateBackingSubsystemwhere
    Context: Send + Sync + CandidateBackingContextTrait + SubsystemContext,
    <Context as CandidateBackingContextTrait>::Sender: CandidateBackingSenderTrait,
    <Context as SubsystemContext>::Sender: CandidateBackingSenderTrait,

impl<Context> Subsystem<Context, SubsystemError> for BitfieldSigningSubsystemwhere
    Context: BitfieldSigningContextTrait + SubsystemContext,
    <Context as BitfieldSigningContextTrait>::Sender: BitfieldSigningSenderTrait,
    <Context as SubsystemContext>::Sender: BitfieldSigningSenderTrait,

impl<Context> Subsystem<Context, SubsystemError> for CandidateValidationSubsystemwhere
    Context: CandidateValidationContextTrait + SubsystemContext,
    <Context as CandidateValidationContextTrait>::Sender: CandidateValidationSenderTrait,
    <Context as SubsystemContext>::Sender: CandidateValidationSenderTrait,

impl<Client, Context> Subsystem<Context, SubsystemError> for ChainApiSubsystem<Client>where
    Client: HeaderBackend<Block> + AuxStore + 'static,
    Context: ChainApiContextTrait + SubsystemContext,
    <Context as ChainApiContextTrait>::Sender: ChainApiSenderTrait,
    <Context as SubsystemContext>::Sender: ChainApiSenderTrait,

impl<Context> Subsystem<Context, SubsystemError> for ChainSelectionSubsystemwhere
    Context: ChainSelectionContextTrait + SubsystemContext,
    <Context as ChainSelectionContextTrait>::Sender: ChainSelectionSenderTrait,
    <Context as SubsystemContext>::Sender: ChainSelectionSenderTrait,

impl<Context> Subsystem<Context, SubsystemError> for DisputeCoordinatorSubsystemwhere
    Context: DisputeCoordinatorContextTrait + SubsystemContext + Send,
    <Context as DisputeCoordinatorContextTrait>::Sender: DisputeCoordinatorSenderTrait,
    <Context as SubsystemContext>::Sender: DisputeCoordinatorSenderTrait,

impl<Context> Subsystem<Context, SubsystemError> for ProvisionerSubsystemwhere
    Context: ProvisionerContextTrait + SubsystemContext,
    <Context as ProvisionerContextTrait>::Sender: ProvisionerSenderTrait,
    <Context as SubsystemContext>::Sender: ProvisionerSenderTrait,

impl<Context> Subsystem<Context, SubsystemError> for PvfCheckerSubsystemwhere
    Context: PvfCheckerContextTrait + SubsystemContext,
    <Context as PvfCheckerContextTrait>::Sender: PvfCheckerSenderTrait,
    <Context as SubsystemContext>::Sender: PvfCheckerSenderTrait,

impl<Client, Context> Subsystem<Context, SubsystemError> for RuntimeApiSubsystem<Client>where
    Client: RuntimeApiSubsystemClient + Send + Sync + 'static,
    Context: RuntimeApiContextTrait + SubsystemContext,
    <Context as RuntimeApiContextTrait>::Sender: RuntimeApiSenderTrait,
    <Context as SubsystemContext>::Sender: RuntimeApiSenderTrait,

impl<Context> Subsystem<Context, SubsystemError> for DummySubsystemwhere
    Context: SubsystemContext<Signal = OverseerSignal, Error = SubsystemError>,

impl<Context, R: Rng + Send + Sync + 'static> Subsystem<Context, SubsystemError> for StatementDistributionSubsystem<R>where
    Context: StatementDistributionContextTrait + SubsystemContext,
    <Context as StatementDistributionContextTrait>::Sender: StatementDistributionSenderTrait,
    <Context as SubsystemContext>::Sender: StatementDistributionSenderTrait,