Struct polkadot_overseer::OverseerSubsystemContext

pub struct OverseerSubsystemContext<M: AssociateOutgoing + Send + 'static> { /* private fields */ }

A context type that is given to the Subsystem upon spawning. It can be used by Subsystem to communicate with other Subsystems or to spawn it’s SubsystemJobs.

Trait Implementations

impl<M: Debug + AssociateOutgoing + Send + 'static> Debug for OverseerSubsystemContext<M>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl SubsystemContext for OverseerSubsystemContext<()>where (): AssociateOutgoing + Debug + Send + 'static, AllMessages: From<()>,

type Message = ()

The message type of this context. Subsystems launched with this context will expect to receive messages of this type. Commonly uses the wrapping enum commonly called AllMessages.

type Signal = OverseerSignal

And the same for signals.

type OutgoingMessages = ()

The overarching messages enum for this particular subsystem.

type Sender = OverseerSender<()>

The sender type as provided by sender() and underlying.

type Error = SubsystemError

The error type.

fn try_recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<Option<FromOrchestra<Self::Message, OverseerSignal>>, ()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Try to asynchronously receive a message.

fn recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<FromOrchestra<Self::Message, OverseerSignal>, SubsystemError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Receive a message.

fn sender(&mut self) -> &mut Self::Sender

Obtain the sender.

fn spawn( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a child task on the executor.

fn spawn_blocking( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a blocking child task on the executor’s dedicated thread pool.

fn send_message<'life0, 'async_trait, T>( &'life0 mut self, msg: T ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, T: Send + 'async_trait, Self: 'async_trait,

Send a direct message to some other Subsystem, routed based on message type.

fn send_messages<'life0, 'async_trait, T, I>( &'life0 mut self, msgs: I ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, I: IntoIterator<Item = T> + Send + 'async_trait, <I as IntoIterator>::IntoIter: Send, T: Send + 'async_trait, Self: 'async_trait,

Send multiple direct messages to other Subsystems, routed based on message type.

fn send_unbounded_message<X>(&mut self, msg: X)where Self::OutgoingMessages: From<X> + Send, X: Send,

Send a message using the unbounded connection.

impl SubsystemContext for OverseerSubsystemContext<ApprovalDistributionMessage>where ApprovalDistributionMessage: AssociateOutgoing + Debug + Send + 'static, AllMessages: From<ApprovalDistributionOutgoingMessages> + From<ApprovalDistributionMessage>, ApprovalDistributionOutgoingMessages: From<NetworkBridgeTxMessage> + From<ApprovalVotingMessage>,

type Message = ApprovalDistributionMessage

The message type of this context. Subsystems launched with this context will expect to receive messages of this type. Commonly uses the wrapping enum commonly called AllMessages.

type Signal = OverseerSignal

And the same for signals.

type OutgoingMessages = ApprovalDistributionOutgoingMessages

The overarching messages enum for this particular subsystem.

type Sender = OverseerSender<ApprovalDistributionOutgoingMessages>

The sender type as provided by sender() and underlying.

type Error = SubsystemError

The error type.

fn try_recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<Option<FromOrchestra<Self::Message, OverseerSignal>>, ()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Try to asynchronously receive a message.

fn recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<FromOrchestra<Self::Message, OverseerSignal>, SubsystemError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Receive a message.

fn sender(&mut self) -> &mut Self::Sender

Obtain the sender.

fn spawn( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a child task on the executor.

fn spawn_blocking( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a blocking child task on the executor’s dedicated thread pool.

fn send_message<'life0, 'async_trait, T>( &'life0 mut self, msg: T ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, T: Send + 'async_trait, Self: 'async_trait,

Send a direct message to some other Subsystem, routed based on message type.

fn send_messages<'life0, 'async_trait, T, I>( &'life0 mut self, msgs: I ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, I: IntoIterator<Item = T> + Send + 'async_trait, <I as IntoIterator>::IntoIter: Send, T: Send + 'async_trait, Self: 'async_trait,

Send multiple direct messages to other Subsystems, routed based on message type.

fn send_unbounded_message<X>(&mut self, msg: X)where Self::OutgoingMessages: From<X> + Send, X: Send,

Send a message using the unbounded connection.

impl SubsystemContext for OverseerSubsystemContext<ApprovalVotingMessage>where ApprovalVotingMessage: AssociateOutgoing + Debug + Send + 'static, AllMessages: From<ApprovalVotingOutgoingMessages> + From<ApprovalVotingMessage>, ApprovalVotingOutgoingMessages: From<ApprovalDistributionMessage> + From<AvailabilityRecoveryMessage> + From<CandidateValidationMessage> + From<ChainApiMessage> + From<ChainSelectionMessage> + From<DisputeCoordinatorMessage> + From<RuntimeApiMessage>,

type Message = ApprovalVotingMessage

The message type of this context. Subsystems launched with this context will expect to receive messages of this type. Commonly uses the wrapping enum commonly called AllMessages.

type Signal = OverseerSignal

And the same for signals.

type OutgoingMessages = ApprovalVotingOutgoingMessages

The overarching messages enum for this particular subsystem.

type Sender = OverseerSender<ApprovalVotingOutgoingMessages>

The sender type as provided by sender() and underlying.

type Error = SubsystemError

The error type.

fn try_recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<Option<FromOrchestra<Self::Message, OverseerSignal>>, ()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Try to asynchronously receive a message.

fn recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<FromOrchestra<Self::Message, OverseerSignal>, SubsystemError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Receive a message.

fn sender(&mut self) -> &mut Self::Sender

Obtain the sender.

fn spawn( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a child task on the executor.

fn spawn_blocking( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a blocking child task on the executor’s dedicated thread pool.

fn send_message<'life0, 'async_trait, T>( &'life0 mut self, msg: T ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, T: Send + 'async_trait, Self: 'async_trait,

Send a direct message to some other Subsystem, routed based on message type.

fn send_messages<'life0, 'async_trait, T, I>( &'life0 mut self, msgs: I ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, I: IntoIterator<Item = T> + Send + 'async_trait, <I as IntoIterator>::IntoIter: Send, T: Send + 'async_trait, Self: 'async_trait,

Send multiple direct messages to other Subsystems, routed based on message type.

fn send_unbounded_message<X>(&mut self, msg: X)where Self::OutgoingMessages: From<X> + Send, X: Send,

Send a message using the unbounded connection.

impl SubsystemContext for OverseerSubsystemContext<AvailabilityDistributionMessage>where AvailabilityDistributionMessage: AssociateOutgoing + Debug + Send + 'static, AllMessages: From<AvailabilityDistributionOutgoingMessages> + From<AvailabilityDistributionMessage>, AvailabilityDistributionOutgoingMessages: From<AvailabilityStoreMessage> + From<AvailabilityRecoveryMessage> + From<ChainApiMessage> + From<RuntimeApiMessage> + From<NetworkBridgeTxMessage>,

type Message = AvailabilityDistributionMessage

The message type of this context. Subsystems launched with this context will expect to receive messages of this type. Commonly uses the wrapping enum commonly called AllMessages.

type Signal = OverseerSignal

And the same for signals.

type OutgoingMessages = AvailabilityDistributionOutgoingMessages

The overarching messages enum for this particular subsystem.

type Sender = OverseerSender<AvailabilityDistributionOutgoingMessages>

The sender type as provided by sender() and underlying.

type Error = SubsystemError

The error type.

fn try_recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<Option<FromOrchestra<Self::Message, OverseerSignal>>, ()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Try to asynchronously receive a message.

fn recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<FromOrchestra<Self::Message, OverseerSignal>, SubsystemError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Receive a message.

fn sender(&mut self) -> &mut Self::Sender

Obtain the sender.

fn spawn( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a child task on the executor.

fn spawn_blocking( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a blocking child task on the executor’s dedicated thread pool.

fn send_message<'life0, 'async_trait, T>( &'life0 mut self, msg: T ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, T: Send + 'async_trait, Self: 'async_trait,

Send a direct message to some other Subsystem, routed based on message type.

fn send_messages<'life0, 'async_trait, T, I>( &'life0 mut self, msgs: I ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, I: IntoIterator<Item = T> + Send + 'async_trait, <I as IntoIterator>::IntoIter: Send, T: Send + 'async_trait, Self: 'async_trait,

Send multiple direct messages to other Subsystems, routed based on message type.

fn send_unbounded_message<X>(&mut self, msg: X)where Self::OutgoingMessages: From<X> + Send, X: Send,

Send a message using the unbounded connection.

impl SubsystemContext for OverseerSubsystemContext<AvailabilityRecoveryMessage>where AvailabilityRecoveryMessage: AssociateOutgoing + Debug + Send + 'static, AllMessages: From<AvailabilityRecoveryOutgoingMessages> + From<AvailabilityRecoveryMessage>, AvailabilityRecoveryOutgoingMessages: From<NetworkBridgeTxMessage> + From<RuntimeApiMessage> + From<AvailabilityStoreMessage>,

type Message = AvailabilityRecoveryMessage

The message type of this context. Subsystems launched with this context will expect to receive messages of this type. Commonly uses the wrapping enum commonly called AllMessages.

type Signal = OverseerSignal

And the same for signals.

type OutgoingMessages = AvailabilityRecoveryOutgoingMessages

The overarching messages enum for this particular subsystem.

type Sender = OverseerSender<AvailabilityRecoveryOutgoingMessages>

The sender type as provided by sender() and underlying.

type Error = SubsystemError

The error type.

fn try_recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<Option<FromOrchestra<Self::Message, OverseerSignal>>, ()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Try to asynchronously receive a message.

fn recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<FromOrchestra<Self::Message, OverseerSignal>, SubsystemError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Receive a message.

fn sender(&mut self) -> &mut Self::Sender

Obtain the sender.

fn spawn( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a child task on the executor.

fn spawn_blocking( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a blocking child task on the executor’s dedicated thread pool.

fn send_message<'life0, 'async_trait, T>( &'life0 mut self, msg: T ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, T: Send + 'async_trait, Self: 'async_trait,

Send a direct message to some other Subsystem, routed based on message type.

fn send_messages<'life0, 'async_trait, T, I>( &'life0 mut self, msgs: I ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, I: IntoIterator<Item = T> + Send + 'async_trait, <I as IntoIterator>::IntoIter: Send, T: Send + 'async_trait, Self: 'async_trait,

Send multiple direct messages to other Subsystems, routed based on message type.

fn send_unbounded_message<X>(&mut self, msg: X)where Self::OutgoingMessages: From<X> + Send, X: Send,

Send a message using the unbounded connection.

impl SubsystemContext for OverseerSubsystemContext<AvailabilityStoreMessage>where AvailabilityStoreMessage: AssociateOutgoing + Debug + Send + 'static, AllMessages: From<AvailabilityStoreOutgoingMessages> + From<AvailabilityStoreMessage>, AvailabilityStoreOutgoingMessages: From<ChainApiMessage> + From<RuntimeApiMessage>,

type Message = AvailabilityStoreMessage

The message type of this context. Subsystems launched with this context will expect to receive messages of this type. Commonly uses the wrapping enum commonly called AllMessages.

type Signal = OverseerSignal

And the same for signals.

type OutgoingMessages = AvailabilityStoreOutgoingMessages

The overarching messages enum for this particular subsystem.

type Sender = OverseerSender<AvailabilityStoreOutgoingMessages>

The sender type as provided by sender() and underlying.

type Error = SubsystemError

The error type.

fn try_recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<Option<FromOrchestra<Self::Message, OverseerSignal>>, ()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Try to asynchronously receive a message.

fn recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<FromOrchestra<Self::Message, OverseerSignal>, SubsystemError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Receive a message.

fn sender(&mut self) -> &mut Self::Sender

Obtain the sender.

fn spawn( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a child task on the executor.

fn spawn_blocking( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a blocking child task on the executor’s dedicated thread pool.

fn send_message<'life0, 'async_trait, T>( &'life0 mut self, msg: T ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, T: Send + 'async_trait, Self: 'async_trait,

Send a direct message to some other Subsystem, routed based on message type.

fn send_messages<'life0, 'async_trait, T, I>( &'life0 mut self, msgs: I ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, I: IntoIterator<Item = T> + Send + 'async_trait, <I as IntoIterator>::IntoIter: Send, T: Send + 'async_trait, Self: 'async_trait,

Send multiple direct messages to other Subsystems, routed based on message type.

fn send_unbounded_message<X>(&mut self, msg: X)where Self::OutgoingMessages: From<X> + Send, X: Send,

Send a message using the unbounded connection.

impl SubsystemContext for OverseerSubsystemContext<BitfieldDistributionMessage>where BitfieldDistributionMessage: AssociateOutgoing + Debug + Send + 'static, AllMessages: From<BitfieldDistributionOutgoingMessages> + From<BitfieldDistributionMessage>, BitfieldDistributionOutgoingMessages: From<RuntimeApiMessage> + From<NetworkBridgeTxMessage> + From<ProvisionerMessage>,

type Message = BitfieldDistributionMessage

The message type of this context. Subsystems launched with this context will expect to receive messages of this type. Commonly uses the wrapping enum commonly called AllMessages.

type Signal = OverseerSignal

And the same for signals.

type OutgoingMessages = BitfieldDistributionOutgoingMessages

The overarching messages enum for this particular subsystem.

type Sender = OverseerSender<BitfieldDistributionOutgoingMessages>

The sender type as provided by sender() and underlying.

type Error = SubsystemError

The error type.

fn try_recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<Option<FromOrchestra<Self::Message, OverseerSignal>>, ()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Try to asynchronously receive a message.

fn recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<FromOrchestra<Self::Message, OverseerSignal>, SubsystemError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Receive a message.

fn sender(&mut self) -> &mut Self::Sender

Obtain the sender.

fn spawn( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a child task on the executor.

fn spawn_blocking( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a blocking child task on the executor’s dedicated thread pool.

fn send_message<'life0, 'async_trait, T>( &'life0 mut self, msg: T ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, T: Send + 'async_trait, Self: 'async_trait,

Send a direct message to some other Subsystem, routed based on message type.

fn send_messages<'life0, 'async_trait, T, I>( &'life0 mut self, msgs: I ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, I: IntoIterator<Item = T> + Send + 'async_trait, <I as IntoIterator>::IntoIter: Send, T: Send + 'async_trait, Self: 'async_trait,

Send multiple direct messages to other Subsystems, routed based on message type.

fn send_unbounded_message<X>(&mut self, msg: X)where Self::OutgoingMessages: From<X> + Send, X: Send,

Send a message using the unbounded connection.

impl SubsystemContext for OverseerSubsystemContext<BitfieldSigningMessage>where BitfieldSigningMessage: AssociateOutgoing + Debug + Send + 'static, AllMessages: From<BitfieldSigningOutgoingMessages> + From<BitfieldSigningMessage>, BitfieldSigningOutgoingMessages: From<AvailabilityStoreMessage> + From<RuntimeApiMessage> + From<BitfieldDistributionMessage>,

type Message = BitfieldSigningMessage

The message type of this context. Subsystems launched with this context will expect to receive messages of this type. Commonly uses the wrapping enum commonly called AllMessages.

type Signal = OverseerSignal

And the same for signals.

type OutgoingMessages = BitfieldSigningOutgoingMessages

The overarching messages enum for this particular subsystem.

type Sender = OverseerSender<BitfieldSigningOutgoingMessages>

The sender type as provided by sender() and underlying.

type Error = SubsystemError

The error type.

fn try_recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<Option<FromOrchestra<Self::Message, OverseerSignal>>, ()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Try to asynchronously receive a message.

fn recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<FromOrchestra<Self::Message, OverseerSignal>, SubsystemError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Receive a message.

fn sender(&mut self) -> &mut Self::Sender

Obtain the sender.

fn spawn( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a child task on the executor.

fn spawn_blocking( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a blocking child task on the executor’s dedicated thread pool.

fn send_message<'life0, 'async_trait, T>( &'life0 mut self, msg: T ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, T: Send + 'async_trait, Self: 'async_trait,

Send a direct message to some other Subsystem, routed based on message type.

fn send_messages<'life0, 'async_trait, T, I>( &'life0 mut self, msgs: I ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, I: IntoIterator<Item = T> + Send + 'async_trait, <I as IntoIterator>::IntoIter: Send, T: Send + 'async_trait, Self: 'async_trait,

Send multiple direct messages to other Subsystems, routed based on message type.

fn send_unbounded_message<X>(&mut self, msg: X)where Self::OutgoingMessages: From<X> + Send, X: Send,

Send a message using the unbounded connection.

impl SubsystemContext for OverseerSubsystemContext<CandidateBackingMessage>where CandidateBackingMessage: AssociateOutgoing + Debug + Send + 'static, AllMessages: From<CandidateBackingOutgoingMessages> + From<CandidateBackingMessage>, CandidateBackingOutgoingMessages: From<CandidateValidationMessage> + From<CollatorProtocolMessage> + From<AvailabilityDistributionMessage> + From<AvailabilityStoreMessage> + From<StatementDistributionMessage> + From<ProvisionerMessage> + From<RuntimeApiMessage>,

type Message = CandidateBackingMessage

The message type of this context. Subsystems launched with this context will expect to receive messages of this type. Commonly uses the wrapping enum commonly called AllMessages.

type Signal = OverseerSignal

And the same for signals.

type OutgoingMessages = CandidateBackingOutgoingMessages

The overarching messages enum for this particular subsystem.

type Sender = OverseerSender<CandidateBackingOutgoingMessages>

The sender type as provided by sender() and underlying.

type Error = SubsystemError

The error type.

fn try_recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<Option<FromOrchestra<Self::Message, OverseerSignal>>, ()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Try to asynchronously receive a message.

fn recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<FromOrchestra<Self::Message, OverseerSignal>, SubsystemError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Receive a message.

fn sender(&mut self) -> &mut Self::Sender

Obtain the sender.

fn spawn( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a child task on the executor.

fn spawn_blocking( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a blocking child task on the executor’s dedicated thread pool.

fn send_message<'life0, 'async_trait, T>( &'life0 mut self, msg: T ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, T: Send + 'async_trait, Self: 'async_trait,

Send a direct message to some other Subsystem, routed based on message type.

fn send_messages<'life0, 'async_trait, T, I>( &'life0 mut self, msgs: I ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, I: IntoIterator<Item = T> + Send + 'async_trait, <I as IntoIterator>::IntoIter: Send, T: Send + 'async_trait, Self: 'async_trait,

Send multiple direct messages to other Subsystems, routed based on message type.

fn send_unbounded_message<X>(&mut self, msg: X)where Self::OutgoingMessages: From<X> + Send, X: Send,

Send a message using the unbounded connection.

impl SubsystemContext for OverseerSubsystemContext<CandidateValidationMessage>where CandidateValidationMessage: AssociateOutgoing + Debug + Send + 'static, AllMessages: From<CandidateValidationOutgoingMessages> + From<CandidateValidationMessage>, CandidateValidationOutgoingMessages: From<RuntimeApiMessage>,

type Message = CandidateValidationMessage

The message type of this context. Subsystems launched with this context will expect to receive messages of this type. Commonly uses the wrapping enum commonly called AllMessages.

type Signal = OverseerSignal

And the same for signals.

type OutgoingMessages = CandidateValidationOutgoingMessages

The overarching messages enum for this particular subsystem.

type Sender = OverseerSender<CandidateValidationOutgoingMessages>

The sender type as provided by sender() and underlying.

type Error = SubsystemError

The error type.

fn try_recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<Option<FromOrchestra<Self::Message, OverseerSignal>>, ()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Try to asynchronously receive a message.

fn recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<FromOrchestra<Self::Message, OverseerSignal>, SubsystemError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Receive a message.

fn sender(&mut self) -> &mut Self::Sender

Obtain the sender.

fn spawn( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a child task on the executor.

fn spawn_blocking( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a blocking child task on the executor’s dedicated thread pool.

fn send_message<'life0, 'async_trait, T>( &'life0 mut self, msg: T ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, T: Send + 'async_trait, Self: 'async_trait,

Send a direct message to some other Subsystem, routed based on message type.

fn send_messages<'life0, 'async_trait, T, I>( &'life0 mut self, msgs: I ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, I: IntoIterator<Item = T> + Send + 'async_trait, <I as IntoIterator>::IntoIter: Send, T: Send + 'async_trait, Self: 'async_trait,

Send multiple direct messages to other Subsystems, routed based on message type.

fn send_unbounded_message<X>(&mut self, msg: X)where Self::OutgoingMessages: From<X> + Send, X: Send,

Send a message using the unbounded connection.

impl SubsystemContext for OverseerSubsystemContext<ChainApiMessage>where ChainApiMessage: AssociateOutgoing + Debug + Send + 'static, AllMessages: From<ChainApiOutgoingMessages> + From<ChainApiMessage>,

type Message = ChainApiMessage

The message type of this context. Subsystems launched with this context will expect to receive messages of this type. Commonly uses the wrapping enum commonly called AllMessages.

type Signal = OverseerSignal

And the same for signals.

type OutgoingMessages = ChainApiOutgoingMessages

The overarching messages enum for this particular subsystem.

type Sender = OverseerSender<ChainApiOutgoingMessages>

The sender type as provided by sender() and underlying.

type Error = SubsystemError

The error type.

fn try_recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<Option<FromOrchestra<Self::Message, OverseerSignal>>, ()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Try to asynchronously receive a message.

fn recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<FromOrchestra<Self::Message, OverseerSignal>, SubsystemError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Receive a message.

fn sender(&mut self) -> &mut Self::Sender

Obtain the sender.

fn spawn( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a child task on the executor.

fn spawn_blocking( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a blocking child task on the executor’s dedicated thread pool.

fn send_message<'life0, 'async_trait, T>( &'life0 mut self, msg: T ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, T: Send + 'async_trait, Self: 'async_trait,

Send a direct message to some other Subsystem, routed based on message type.

fn send_messages<'life0, 'async_trait, T, I>( &'life0 mut self, msgs: I ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, I: IntoIterator<Item = T> + Send + 'async_trait, <I as IntoIterator>::IntoIter: Send, T: Send + 'async_trait, Self: 'async_trait,

Send multiple direct messages to other Subsystems, routed based on message type.

fn send_unbounded_message<X>(&mut self, msg: X)where Self::OutgoingMessages: From<X> + Send, X: Send,

Send a message using the unbounded connection.

impl SubsystemContext for OverseerSubsystemContext<ChainSelectionMessage>where ChainSelectionMessage: AssociateOutgoing + Debug + Send + 'static, AllMessages: From<ChainSelectionOutgoingMessages> + From<ChainSelectionMessage>, ChainSelectionOutgoingMessages: From<ChainApiMessage>,

type Message = ChainSelectionMessage

The message type of this context. Subsystems launched with this context will expect to receive messages of this type. Commonly uses the wrapping enum commonly called AllMessages.

type Signal = OverseerSignal

And the same for signals.

type OutgoingMessages = ChainSelectionOutgoingMessages

The overarching messages enum for this particular subsystem.

type Sender = OverseerSender<ChainSelectionOutgoingMessages>

The sender type as provided by sender() and underlying.

type Error = SubsystemError

The error type.

fn try_recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<Option<FromOrchestra<Self::Message, OverseerSignal>>, ()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Try to asynchronously receive a message.

fn recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<FromOrchestra<Self::Message, OverseerSignal>, SubsystemError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Receive a message.

fn sender(&mut self) -> &mut Self::Sender

Obtain the sender.

fn spawn( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a child task on the executor.

fn spawn_blocking( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a blocking child task on the executor’s dedicated thread pool.

fn send_message<'life0, 'async_trait, T>( &'life0 mut self, msg: T ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, T: Send + 'async_trait, Self: 'async_trait,

Send a direct message to some other Subsystem, routed based on message type.

fn send_messages<'life0, 'async_trait, T, I>( &'life0 mut self, msgs: I ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, I: IntoIterator<Item = T> + Send + 'async_trait, <I as IntoIterator>::IntoIter: Send, T: Send + 'async_trait, Self: 'async_trait,

Send multiple direct messages to other Subsystems, routed based on message type.

fn send_unbounded_message<X>(&mut self, msg: X)where Self::OutgoingMessages: From<X> + Send, X: Send,

Send a message using the unbounded connection.

impl SubsystemContext for OverseerSubsystemContext<CollationGenerationMessage>where CollationGenerationMessage: AssociateOutgoing + Debug + Send + 'static, AllMessages: From<CollationGenerationOutgoingMessages> + From<CollationGenerationMessage>, CollationGenerationOutgoingMessages: From<RuntimeApiMessage> + From<CollatorProtocolMessage>,

type Message = CollationGenerationMessage

The message type of this context. Subsystems launched with this context will expect to receive messages of this type. Commonly uses the wrapping enum commonly called AllMessages.

type Signal = OverseerSignal

And the same for signals.

type OutgoingMessages = CollationGenerationOutgoingMessages

The overarching messages enum for this particular subsystem.

type Sender = OverseerSender<CollationGenerationOutgoingMessages>

The sender type as provided by sender() and underlying.

type Error = SubsystemError

The error type.

fn try_recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<Option<FromOrchestra<Self::Message, OverseerSignal>>, ()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Try to asynchronously receive a message.

fn recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<FromOrchestra<Self::Message, OverseerSignal>, SubsystemError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Receive a message.

fn sender(&mut self) -> &mut Self::Sender

Obtain the sender.

fn spawn( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a child task on the executor.

fn spawn_blocking( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a blocking child task on the executor’s dedicated thread pool.

fn send_message<'life0, 'async_trait, T>( &'life0 mut self, msg: T ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, T: Send + 'async_trait, Self: 'async_trait,

Send a direct message to some other Subsystem, routed based on message type.

fn send_messages<'life0, 'async_trait, T, I>( &'life0 mut self, msgs: I ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, I: IntoIterator<Item = T> + Send + 'async_trait, <I as IntoIterator>::IntoIter: Send, T: Send + 'async_trait, Self: 'async_trait,

Send multiple direct messages to other Subsystems, routed based on message type.

fn send_unbounded_message<X>(&mut self, msg: X)where Self::OutgoingMessages: From<X> + Send, X: Send,

Send a message using the unbounded connection.

impl SubsystemContext for OverseerSubsystemContext<CollatorProtocolMessage>where CollatorProtocolMessage: AssociateOutgoing + Debug + Send + 'static, AllMessages: From<CollatorProtocolOutgoingMessages> + From<CollatorProtocolMessage>, CollatorProtocolOutgoingMessages: From<NetworkBridgeTxMessage> + From<RuntimeApiMessage> + From<CandidateBackingMessage>,

type Message = CollatorProtocolMessage

The message type of this context. Subsystems launched with this context will expect to receive messages of this type. Commonly uses the wrapping enum commonly called AllMessages.

type Signal = OverseerSignal

And the same for signals.

type OutgoingMessages = CollatorProtocolOutgoingMessages

The overarching messages enum for this particular subsystem.

type Sender = OverseerSender<CollatorProtocolOutgoingMessages>

The sender type as provided by sender() and underlying.

type Error = SubsystemError

The error type.

fn try_recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<Option<FromOrchestra<Self::Message, OverseerSignal>>, ()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Try to asynchronously receive a message.

fn recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<FromOrchestra<Self::Message, OverseerSignal>, SubsystemError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Receive a message.

fn sender(&mut self) -> &mut Self::Sender

Obtain the sender.

fn spawn( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a child task on the executor.

fn spawn_blocking( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a blocking child task on the executor’s dedicated thread pool.

fn send_message<'life0, 'async_trait, T>( &'life0 mut self, msg: T ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, T: Send + 'async_trait, Self: 'async_trait,

Send a direct message to some other Subsystem, routed based on message type.

fn send_messages<'life0, 'async_trait, T, I>( &'life0 mut self, msgs: I ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, I: IntoIterator<Item = T> + Send + 'async_trait, <I as IntoIterator>::IntoIter: Send, T: Send + 'async_trait, Self: 'async_trait,

Send multiple direct messages to other Subsystems, routed based on message type.

fn send_unbounded_message<X>(&mut self, msg: X)where Self::OutgoingMessages: From<X> + Send, X: Send,

Send a message using the unbounded connection.

impl SubsystemContext for OverseerSubsystemContext<DisputeCoordinatorMessage>where DisputeCoordinatorMessage: AssociateOutgoing + Debug + Send + 'static, AllMessages: From<DisputeCoordinatorOutgoingMessages> + From<DisputeCoordinatorMessage>, DisputeCoordinatorOutgoingMessages: From<RuntimeApiMessage> + From<ChainApiMessage> + From<DisputeDistributionMessage> + From<CandidateValidationMessage> + From<ApprovalVotingMessage> + From<AvailabilityStoreMessage> + From<AvailabilityRecoveryMessage>,

type Message = DisputeCoordinatorMessage

The message type of this context. Subsystems launched with this context will expect to receive messages of this type. Commonly uses the wrapping enum commonly called AllMessages.

type Signal = OverseerSignal

And the same for signals.

type OutgoingMessages = DisputeCoordinatorOutgoingMessages

The overarching messages enum for this particular subsystem.

type Sender = OverseerSender<DisputeCoordinatorOutgoingMessages>

The sender type as provided by sender() and underlying.

type Error = SubsystemError

The error type.

fn try_recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<Option<FromOrchestra<Self::Message, OverseerSignal>>, ()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Try to asynchronously receive a message.

fn recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<FromOrchestra<Self::Message, OverseerSignal>, SubsystemError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Receive a message.

fn sender(&mut self) -> &mut Self::Sender

Obtain the sender.

fn spawn( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a child task on the executor.

fn spawn_blocking( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a blocking child task on the executor’s dedicated thread pool.

fn send_message<'life0, 'async_trait, T>( &'life0 mut self, msg: T ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, T: Send + 'async_trait, Self: 'async_trait,

Send a direct message to some other Subsystem, routed based on message type.

fn send_messages<'life0, 'async_trait, T, I>( &'life0 mut self, msgs: I ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, I: IntoIterator<Item = T> + Send + 'async_trait, <I as IntoIterator>::IntoIter: Send, T: Send + 'async_trait, Self: 'async_trait,

Send multiple direct messages to other Subsystems, routed based on message type.

fn send_unbounded_message<X>(&mut self, msg: X)where Self::OutgoingMessages: From<X> + Send, X: Send,

Send a message using the unbounded connection.

impl SubsystemContext for OverseerSubsystemContext<DisputeDistributionMessage>where DisputeDistributionMessage: AssociateOutgoing + Debug + Send + 'static, AllMessages: From<DisputeDistributionOutgoingMessages> + From<DisputeDistributionMessage>, DisputeDistributionOutgoingMessages: From<RuntimeApiMessage> + From<DisputeCoordinatorMessage> + From<NetworkBridgeTxMessage>,

type Message = DisputeDistributionMessage

The message type of this context. Subsystems launched with this context will expect to receive messages of this type. Commonly uses the wrapping enum commonly called AllMessages.

type Signal = OverseerSignal

And the same for signals.

type OutgoingMessages = DisputeDistributionOutgoingMessages

The overarching messages enum for this particular subsystem.

type Sender = OverseerSender<DisputeDistributionOutgoingMessages>

The sender type as provided by sender() and underlying.

type Error = SubsystemError

The error type.

fn try_recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<Option<FromOrchestra<Self::Message, OverseerSignal>>, ()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Try to asynchronously receive a message.

fn recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<FromOrchestra<Self::Message, OverseerSignal>, SubsystemError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Receive a message.

fn sender(&mut self) -> &mut Self::Sender

Obtain the sender.

fn spawn( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a child task on the executor.

fn spawn_blocking( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a blocking child task on the executor’s dedicated thread pool.

fn send_message<'life0, 'async_trait, T>( &'life0 mut self, msg: T ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, T: Send + 'async_trait, Self: 'async_trait,

Send a direct message to some other Subsystem, routed based on message type.

fn send_messages<'life0, 'async_trait, T, I>( &'life0 mut self, msgs: I ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, I: IntoIterator<Item = T> + Send + 'async_trait, <I as IntoIterator>::IntoIter: Send, T: Send + 'async_trait, Self: 'async_trait,

Send multiple direct messages to other Subsystems, routed based on message type.

fn send_unbounded_message<X>(&mut self, msg: X)where Self::OutgoingMessages: From<X> + Send, X: Send,

Send a message using the unbounded connection.

impl SubsystemContext for OverseerSubsystemContext<GossipSupportMessage>where GossipSupportMessage: AssociateOutgoing + Debug + Send + 'static, AllMessages: From<GossipSupportOutgoingMessages> + From<GossipSupportMessage>, GossipSupportOutgoingMessages: From<NetworkBridgeTxMessage> + From<NetworkBridgeRxMessage> + From<RuntimeApiMessage> + From<ChainSelectionMessage>,

type Message = GossipSupportMessage

The message type of this context. Subsystems launched with this context will expect to receive messages of this type. Commonly uses the wrapping enum commonly called AllMessages.

type Signal = OverseerSignal

And the same for signals.

type OutgoingMessages = GossipSupportOutgoingMessages

The overarching messages enum for this particular subsystem.

type Sender = OverseerSender<GossipSupportOutgoingMessages>

The sender type as provided by sender() and underlying.

type Error = SubsystemError

The error type.

fn try_recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<Option<FromOrchestra<Self::Message, OverseerSignal>>, ()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Try to asynchronously receive a message.

fn recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<FromOrchestra<Self::Message, OverseerSignal>, SubsystemError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Receive a message.

fn sender(&mut self) -> &mut Self::Sender

Obtain the sender.

fn spawn( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a child task on the executor.

fn spawn_blocking( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a blocking child task on the executor’s dedicated thread pool.

fn send_message<'life0, 'async_trait, T>( &'life0 mut self, msg: T ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, T: Send + 'async_trait, Self: 'async_trait,

Send a direct message to some other Subsystem, routed based on message type.

fn send_messages<'life0, 'async_trait, T, I>( &'life0 mut self, msgs: I ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, I: IntoIterator<Item = T> + Send + 'async_trait, <I as IntoIterator>::IntoIter: Send, T: Send + 'async_trait, Self: 'async_trait,

Send multiple direct messages to other Subsystems, routed based on message type.

fn send_unbounded_message<X>(&mut self, msg: X)where Self::OutgoingMessages: From<X> + Send, X: Send,

Send a message using the unbounded connection.

impl SubsystemContext for OverseerSubsystemContext<NetworkBridgeRxMessage>where NetworkBridgeRxMessage: AssociateOutgoing + Debug + Send + 'static, AllMessages: From<NetworkBridgeRxOutgoingMessages> + From<NetworkBridgeRxMessage>, NetworkBridgeRxOutgoingMessages: From<BitfieldDistributionMessage> + From<StatementDistributionMessage> + From<ApprovalDistributionMessage> + From<GossipSupportMessage> + From<DisputeDistributionMessage> + From<CollationGenerationMessage> + From<CollatorProtocolMessage>,

type Message = NetworkBridgeRxMessage

The message type of this context. Subsystems launched with this context will expect to receive messages of this type. Commonly uses the wrapping enum commonly called AllMessages.

type Signal = OverseerSignal

And the same for signals.

type OutgoingMessages = NetworkBridgeRxOutgoingMessages

The overarching messages enum for this particular subsystem.

type Sender = OverseerSender<NetworkBridgeRxOutgoingMessages>

The sender type as provided by sender() and underlying.

type Error = SubsystemError

The error type.

fn try_recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<Option<FromOrchestra<Self::Message, OverseerSignal>>, ()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Try to asynchronously receive a message.

fn recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<FromOrchestra<Self::Message, OverseerSignal>, SubsystemError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Receive a message.

fn sender(&mut self) -> &mut Self::Sender

Obtain the sender.

fn spawn( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a child task on the executor.

fn spawn_blocking( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a blocking child task on the executor’s dedicated thread pool.

fn send_message<'life0, 'async_trait, T>( &'life0 mut self, msg: T ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, T: Send + 'async_trait, Self: 'async_trait,

Send a direct message to some other Subsystem, routed based on message type.

fn send_messages<'life0, 'async_trait, T, I>( &'life0 mut self, msgs: I ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, I: IntoIterator<Item = T> + Send + 'async_trait, <I as IntoIterator>::IntoIter: Send, T: Send + 'async_trait, Self: 'async_trait,

Send multiple direct messages to other Subsystems, routed based on message type.

fn send_unbounded_message<X>(&mut self, msg: X)where Self::OutgoingMessages: From<X> + Send, X: Send,

Send a message using the unbounded connection.

impl SubsystemContext for OverseerSubsystemContext<NetworkBridgeTxMessage>where NetworkBridgeTxMessage: AssociateOutgoing + Debug + Send + 'static, AllMessages: From<NetworkBridgeTxOutgoingMessages> + From<NetworkBridgeTxMessage>,

type Message = NetworkBridgeTxMessage

The message type of this context. Subsystems launched with this context will expect to receive messages of this type. Commonly uses the wrapping enum commonly called AllMessages.

type Signal = OverseerSignal

And the same for signals.

type OutgoingMessages = NetworkBridgeTxOutgoingMessages

The overarching messages enum for this particular subsystem.

type Sender = OverseerSender<NetworkBridgeTxOutgoingMessages>

The sender type as provided by sender() and underlying.

type Error = SubsystemError

The error type.

fn try_recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<Option<FromOrchestra<Self::Message, OverseerSignal>>, ()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Try to asynchronously receive a message.

fn recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<FromOrchestra<Self::Message, OverseerSignal>, SubsystemError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Receive a message.

fn sender(&mut self) -> &mut Self::Sender

Obtain the sender.

fn spawn( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a child task on the executor.

fn spawn_blocking( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a blocking child task on the executor’s dedicated thread pool.

fn send_message<'life0, 'async_trait, T>( &'life0 mut self, msg: T ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, T: Send + 'async_trait, Self: 'async_trait,

Send a direct message to some other Subsystem, routed based on message type.

fn send_messages<'life0, 'async_trait, T, I>( &'life0 mut self, msgs: I ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, I: IntoIterator<Item = T> + Send + 'async_trait, <I as IntoIterator>::IntoIter: Send, T: Send + 'async_trait, Self: 'async_trait,

Send multiple direct messages to other Subsystems, routed based on message type.

fn send_unbounded_message<X>(&mut self, msg: X)where Self::OutgoingMessages: From<X> + Send, X: Send,

Send a message using the unbounded connection.

impl SubsystemContext for OverseerSubsystemContext<ProvisionerMessage>where ProvisionerMessage: AssociateOutgoing + Debug + Send + 'static, AllMessages: From<ProvisionerOutgoingMessages> + From<ProvisionerMessage>, ProvisionerOutgoingMessages: From<RuntimeApiMessage> + From<CandidateBackingMessage> + From<ChainApiMessage> + From<DisputeCoordinatorMessage>,

type Message = ProvisionerMessage

The message type of this context. Subsystems launched with this context will expect to receive messages of this type. Commonly uses the wrapping enum commonly called AllMessages.

type Signal = OverseerSignal

And the same for signals.

type OutgoingMessages = ProvisionerOutgoingMessages

The overarching messages enum for this particular subsystem.

type Sender = OverseerSender<ProvisionerOutgoingMessages>

The sender type as provided by sender() and underlying.

type Error = SubsystemError

The error type.

fn try_recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<Option<FromOrchestra<Self::Message, OverseerSignal>>, ()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Try to asynchronously receive a message.

fn recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<FromOrchestra<Self::Message, OverseerSignal>, SubsystemError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Receive a message.

fn sender(&mut self) -> &mut Self::Sender

Obtain the sender.

fn spawn( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a child task on the executor.

fn spawn_blocking( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a blocking child task on the executor’s dedicated thread pool.

fn send_message<'life0, 'async_trait, T>( &'life0 mut self, msg: T ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, T: Send + 'async_trait, Self: 'async_trait,

Send a direct message to some other Subsystem, routed based on message type.

fn send_messages<'life0, 'async_trait, T, I>( &'life0 mut self, msgs: I ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, I: IntoIterator<Item = T> + Send + 'async_trait, <I as IntoIterator>::IntoIter: Send, T: Send + 'async_trait, Self: 'async_trait,

Send multiple direct messages to other Subsystems, routed based on message type.

fn send_unbounded_message<X>(&mut self, msg: X)where Self::OutgoingMessages: From<X> + Send, X: Send,

Send a message using the unbounded connection.

impl SubsystemContext for OverseerSubsystemContext<PvfCheckerMessage>where PvfCheckerMessage: AssociateOutgoing + Debug + Send + 'static, AllMessages: From<PvfCheckerOutgoingMessages> + From<PvfCheckerMessage>, PvfCheckerOutgoingMessages: From<CandidateValidationMessage> + From<RuntimeApiMessage>,

type Message = PvfCheckerMessage

The message type of this context. Subsystems launched with this context will expect to receive messages of this type. Commonly uses the wrapping enum commonly called AllMessages.

type Signal = OverseerSignal

And the same for signals.

type OutgoingMessages = PvfCheckerOutgoingMessages

The overarching messages enum for this particular subsystem.

type Sender = OverseerSender<PvfCheckerOutgoingMessages>

The sender type as provided by sender() and underlying.

type Error = SubsystemError

The error type.

fn try_recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<Option<FromOrchestra<Self::Message, OverseerSignal>>, ()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Try to asynchronously receive a message.

fn recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<FromOrchestra<Self::Message, OverseerSignal>, SubsystemError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Receive a message.

fn sender(&mut self) -> &mut Self::Sender

Obtain the sender.

fn spawn( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a child task on the executor.

fn spawn_blocking( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a blocking child task on the executor’s dedicated thread pool.

fn send_message<'life0, 'async_trait, T>( &'life0 mut self, msg: T ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, T: Send + 'async_trait, Self: 'async_trait,

Send a direct message to some other Subsystem, routed based on message type.

fn send_messages<'life0, 'async_trait, T, I>( &'life0 mut self, msgs: I ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, I: IntoIterator<Item = T> + Send + 'async_trait, <I as IntoIterator>::IntoIter: Send, T: Send + 'async_trait, Self: 'async_trait,

Send multiple direct messages to other Subsystems, routed based on message type.

fn send_unbounded_message<X>(&mut self, msg: X)where Self::OutgoingMessages: From<X> + Send, X: Send,

Send a message using the unbounded connection.

impl SubsystemContext for OverseerSubsystemContext<RuntimeApiMessage>where RuntimeApiMessage: AssociateOutgoing + Debug + Send + 'static, AllMessages: From<RuntimeApiOutgoingMessages> + From<RuntimeApiMessage>,

type Message = RuntimeApiMessage

The message type of this context. Subsystems launched with this context will expect to receive messages of this type. Commonly uses the wrapping enum commonly called AllMessages.

type Signal = OverseerSignal

And the same for signals.

type OutgoingMessages = RuntimeApiOutgoingMessages

The overarching messages enum for this particular subsystem.

type Sender = OverseerSender<RuntimeApiOutgoingMessages>

The sender type as provided by sender() and underlying.

type Error = SubsystemError

The error type.

fn try_recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<Option<FromOrchestra<Self::Message, OverseerSignal>>, ()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Try to asynchronously receive a message.

fn recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<FromOrchestra<Self::Message, OverseerSignal>, SubsystemError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Receive a message.

fn sender(&mut self) -> &mut Self::Sender

Obtain the sender.

fn spawn( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a child task on the executor.

fn spawn_blocking( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a blocking child task on the executor’s dedicated thread pool.

fn send_message<'life0, 'async_trait, T>( &'life0 mut self, msg: T ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, T: Send + 'async_trait, Self: 'async_trait,

Send a direct message to some other Subsystem, routed based on message type.

fn send_messages<'life0, 'async_trait, T, I>( &'life0 mut self, msgs: I ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, I: IntoIterator<Item = T> + Send + 'async_trait, <I as IntoIterator>::IntoIter: Send, T: Send + 'async_trait, Self: 'async_trait,

Send multiple direct messages to other Subsystems, routed based on message type.

fn send_unbounded_message<X>(&mut self, msg: X)where Self::OutgoingMessages: From<X> + Send, X: Send,

Send a message using the unbounded connection.

impl SubsystemContext for OverseerSubsystemContext<StatementDistributionMessage>where StatementDistributionMessage: AssociateOutgoing + Debug + Send + 'static, AllMessages: From<StatementDistributionOutgoingMessages> + From<StatementDistributionMessage>, StatementDistributionOutgoingMessages: From<NetworkBridgeTxMessage> + From<CandidateBackingMessage> + From<RuntimeApiMessage>,

type Message = StatementDistributionMessage

The message type of this context. Subsystems launched with this context will expect to receive messages of this type. Commonly uses the wrapping enum commonly called AllMessages.

type Signal = OverseerSignal

And the same for signals.

type OutgoingMessages = StatementDistributionOutgoingMessages

The overarching messages enum for this particular subsystem.

type Sender = OverseerSender<StatementDistributionOutgoingMessages>

The sender type as provided by sender() and underlying.

type Error = SubsystemError

The error type.

fn try_recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<Option<FromOrchestra<Self::Message, OverseerSignal>>, ()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Try to asynchronously receive a message.

fn recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<FromOrchestra<Self::Message, OverseerSignal>, SubsystemError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Receive a message.

fn sender(&mut self) -> &mut Self::Sender

Obtain the sender.

fn spawn( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a child task on the executor.

fn spawn_blocking( &mut self, name: &'static str, s: Pin<Box<dyn Future<Output = ()> + Send>> ) -> Result<(), SubsystemError>

Spawn a blocking child task on the executor’s dedicated thread pool.

fn send_message<'life0, 'async_trait, T>( &'life0 mut self, msg: T ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, T: Send + 'async_trait, Self: 'async_trait,

Send a direct message to some other Subsystem, routed based on message type.

fn send_messages<'life0, 'async_trait, T, I>( &'life0 mut self, msgs: I ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self::OutgoingMessages: From<T> + Send, I: IntoIterator<Item = T> + Send + 'async_trait, <I as IntoIterator>::IntoIter: Send, T: Send + 'async_trait, Self: 'async_trait,

Send multiple direct messages to other Subsystems, routed based on message type.

fn send_unbounded_message<X>(&mut self, msg: X)where Self::OutgoingMessages: From<X> + Send, X: Send,

Send a message using the unbounded connection.