Crate polkadot_node_subsystem

Subsystem accumulation.

Node-side types and generated overseer.

Re-exports

• pub use polkadot_node_jaeger as jaeger;
• pub use polkadot_overseer as overseer;

Modules

• dummy
  A dummy subsystem, mostly useful for placeholders and tests.
• errors
  Error types for the subsystem requests.
• gen
  Orchestra
• jaeger
  Polkadot Jaeger related primitives
• messages
  Re-export of all messages type, including the wrapper type.
• metrics
  Prometheus metrics related to the overseer and its channels.

Structs

• ActivatedLeaf
  Activated leaf.
• ActiveLeavesUpdate
  Changes in the set of active leaves: the parachain heads which we care to work on.
• BlockInfo
  An event telling the Overseer on the particular block that has been imported or finalized.
• ChainApiError
  A description of an error causing the chain API request to be unservable.
• ChannelsOut
  Collection of channels to the individual subsystems.
• DummySubsystem
  A dummy subsystem that implements Subsystem for all types of messages. Used for tests or as a placeholder.
• Handle
  A handle used to communicate with the Overseer.
• JaegerConfig
  Configuration for the jaeger tracing.
• JaegerConfigBuilder
  Jaeger configuration builder.
• MessagePacket
  A wrapping type for messages.
• Metronome
  Create a stream of ticks with a defined cycle duration.
• Missing
  Type marker for the uninitialized field of the orchestra builder. PhantomData is used for type hinting when creating uninitialized builder, e.g. to avoid specifying the generics when instantiating the FooBuilder when calling Foo::builder()
• OrchestratedSubsystem
  A subsystem that the orchestrator orchestrates.
• Overseer
  The orchestra.
• OverseerBuilder
  Builder pattern to create compile time safe construction path.
• OverseerConnector
  External connector.
• OverseerMetrics
  A shareable metrics type for usage with the overseer.
• OverseerSender
  Connector to send messages towards all subsystems, while tracking the which signals where already received.
• OverseerSubsystemContext
  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.
• PerLeafSpan
  A special “per leaf span”.
• SignalsReceived
  Watermark to track the received signals.
• SpawnGlue
  Glue to connect trait orchestra::Spawner and SpawnNamed from substrate.
• SubsystemMeterReadouts
  Set of readouts of the Meters of a subsystem.
• SubsystemMeters
  Collection of meters related to a subsystem.

Enums

• AllMessages
  Generated message type wrapper over all possible messages used by any subsystem.
• ApprovalDistributionOutgoingMessages
• ApprovalVotingOutgoingMessages
• AvailabilityDistributionOutgoingMessages
• AvailabilityRecoveryOutgoingMessages
• AvailabilityStoreOutgoingMessages
• BitfieldDistributionOutgoingMessages
• BitfieldSigningOutgoingMessages
• CandidateBackingOutgoingMessages
• CandidateValidationOutgoingMessages
• ChainApiOutgoingMessages
• ChainSelectionOutgoingMessages
• CollationGenerationOutgoingMessages
• CollatorProtocolOutgoingMessages
• DisputeCoordinatorOutgoingMessages
• DisputeDistributionOutgoingMessages
• Event
  An event from outside the overseer scope, such as the substrate framework or user interaction.
• ExternalRequest
  Some request from outer world.
• GossipSupportOutgoingMessages
• Init
  Type for the initialized field of the orchestra builder
• Jaeger
  Stateful convenience wrapper around mick_jaeger.
• JaegerError
  A description of an error during jaeger initialization.
• LeafStatus
  The status of an activated leaf.
• NetworkBridgeRxOutgoingMessages
• NetworkBridgeTxOutgoingMessages
• OverseerError
  An error type that describes faults that may happen
• OverseerSignal
  Signals sent by an overseer to a subsystem.
• ProvisionerOutgoingMessages
• PvfCheckerOutgoingMessages
• RecoveryError
  An error that may happen during Availability Recovery process.
• RuntimeApiError
  A description of an error causing the runtime API request to be unservable.
• RuntimeApiOutgoingMessages
• Span
  A wrapper type for a span.
• Stage
  A helper to annotate the stage with a numerical value to ease the life of the tooling team creating viable statistical metrics for which stage of the inclusion pipeline drops a significant amount of candidates, statistically speaking.
• StatementDistributionOutgoingMessages
• SubsystemError
  An error type that describes faults that may happen
• ToOrchestra
  A type of messages that are sent from a Subsystem to the declared orchestra.

Constants

• KNOWN_LEAVES_CACHE_SIZE
  Store 2 days worth of blocks, not accounting for forks, in the LRU cache. Assumes a 6-second block time.

Traits

• ApprovalDistributionContextTrait
  Accumulative trait for a particular subsystem wrapper.
• ApprovalDistributionSenderTrait
  A abstracting trait for usage with subsystems.
• ApprovalVotingContextTrait
  Accumulative trait for a particular subsystem wrapper.
• ApprovalVotingSenderTrait
  A abstracting trait for usage with subsystems.
• AssociateOutgoing
  Binds a generated type covering all declared outgoing messages, which implements #generated_outgoing: From<M> for all annotated types of a particular subsystem.
• AvailabilityDistributionContextTrait
  Accumulative trait for a particular subsystem wrapper.
• AvailabilityDistributionSenderTrait
  A abstracting trait for usage with subsystems.
• AvailabilityRecoveryContextTrait
  Accumulative trait for a particular subsystem wrapper.
• AvailabilityRecoverySenderTrait
  A abstracting trait for usage with subsystems.
• AvailabilityStoreContextTrait
  Accumulative trait for a particular subsystem wrapper.
• AvailabilityStoreSenderTrait
  A abstracting trait for usage with subsystems.
• BitfieldDistributionContextTrait
  Accumulative trait for a particular subsystem wrapper.
• BitfieldDistributionSenderTrait
  A abstracting trait for usage with subsystems.
• BitfieldSigningContextTrait
  Accumulative trait for a particular subsystem wrapper.
• BitfieldSigningSenderTrait
  A abstracting trait for usage with subsystems.
• CandidateBackingContextTrait
  Accumulative trait for a particular subsystem wrapper.
• CandidateBackingSenderTrait
  A abstracting trait for usage with subsystems.
• CandidateValidationContextTrait
  Accumulative trait for a particular subsystem wrapper.
• CandidateValidationSenderTrait
  A abstracting trait for usage with subsystems.
• ChainApiContextTrait
  Accumulative trait for a particular subsystem wrapper.
• ChainApiSenderTrait
  A abstracting trait for usage with subsystems.
• ChainSelectionContextTrait
  Accumulative trait for a particular subsystem wrapper.
• ChainSelectionSenderTrait
  A abstracting trait for usage with subsystems.
• CollationGenerationContextTrait
  Accumulative trait for a particular subsystem wrapper.
• CollationGenerationSenderTrait
  A abstracting trait for usage with subsystems.
• CollatorProtocolContextTrait
  Accumulative trait for a particular subsystem wrapper.
• CollatorProtocolSenderTrait
  A abstracting trait for usage with subsystems.
• DisputeCoordinatorContextTrait
  Accumulative trait for a particular subsystem wrapper.
• DisputeCoordinatorSenderTrait
  A abstracting trait for usage with subsystems.
• DisputeDistributionContextTrait
  Accumulative trait for a particular subsystem wrapper.
• DisputeDistributionSenderTrait
  A abstracting trait for usage with subsystems.
• GossipSupportContextTrait
  Accumulative trait for a particular subsystem wrapper.
• GossipSupportSenderTrait
  A abstracting trait for usage with subsystems.
• HeadSupportsParachains
  Whether a header supports parachain consensus or not.
• MapSubsystem
  A helper trait to map a subsystem to smth. else.
• MetricsTrait
  Subsystem- or job-specific Prometheus metrics.
• NetworkBridgeRxContextTrait
  Accumulative trait for a particular subsystem wrapper.
• NetworkBridgeRxSenderTrait
  A abstracting trait for usage with subsystems.
• NetworkBridgeTxContextTrait
  Accumulative trait for a particular subsystem wrapper.
• NetworkBridgeTxSenderTrait
  A abstracting trait for usage with subsystems.
• ProvisionerContextTrait
  Accumulative trait for a particular subsystem wrapper.
• ProvisionerSenderTrait
  A abstracting trait for usage with subsystems.
• PvfCheckerContextTrait
  Accumulative trait for a particular subsystem wrapper.
• PvfCheckerSenderTrait
  A abstracting trait for usage with subsystems.
• RuntimeApiContextTrait
  Accumulative trait for a particular subsystem wrapper.
• RuntimeApiSenderTrait
  A abstracting trait for usage with subsystems.
• RuntimeApiSubsystemClient
  Exposes all runtime calls that are used by the runtime API subsystem.
• Spawner
  A spawner
• StatementDistributionContextTrait
  Accumulative trait for a particular subsystem wrapper.
• StatementDistributionSenderTrait
  A abstracting trait for usage with subsystems.
• Subsystem
  A trait that describes the Subsystems that can run on the Orchestra.
• SubsystemContext
  A context type that is given to the Subsystem upon spawning. It can be used by Subsystem to communicate with other Subsystems or spawn jobs.
• SubsystemSender
  Sender end of a channel to interface with a subsystem.
• TaskKind
  Task kind to launch.
• TimeoutExt
  Extends Future to allow time-limited futures.

Functions

• forward_events
  Glues together the Overseer and BlockchainEvents by forwarding import and finality notifications into the OverseerHandle.
• hash_to_trace_identifier
  A helper to convert the hash to the fixed size representation needed for jaeger.
• spawn
  Spawn task of kind self using spawner S.
• spawn_metronome_metrics
  Spawn the metrics metronome task.

Type Definitions

• FromOrchestra
  Specialized message type originating from the overseer.
• InitializedOverseerBuilder
  Type used to represent a builder where all fields are initialized and the orchestra could be constructed.
• OverseerHandle
  Handle for an orchestra.
• SpawnedSubsystem
  Spawned subsystem.
• SubsystemIncomingMessages
  Incoming messages from both the bounded and unbounded channel.
• SubsystemInstance
  Specialized subsystem instance type of subsystems consuming a particular message type.
• SubsystemResult
  A Result type that wraps SubsystemError.

Attribute Macros

• contextbounds
• gen
• orchestra
• subsystem