Struct polkadot_service::overseer::OverseerGenArgs

source ·

pub struct OverseerGenArgs<'a, Spawner, RuntimeClient>where
    RuntimeClient: 'static + ProvideRuntimeApi<Block> + HeaderBackend<Block> + AuxStore,
    RuntimeClient::Api: ParachainHost<Block> + BabeApi<Block> + AuthorityDiscoveryApi<Block>,
    Spawner: 'static + SpawnNamed + Clone + Unpin,{Show 24 fields
    pub leaves: Vec<BlockInfo>,
    pub keystore: Arc<LocalKeystore>,
    pub runtime_client: Arc<RuntimeClient>,
    pub parachains_db: Arc<dyn Database>,
    pub network_service: Arc<NetworkService<Block, Hash>>,
    pub authority_discovery_service: AuthorityDiscoveryService,
    pub pov_req_receiver: IncomingRequestReceiver<PoVFetchingRequest>,
    pub chunk_req_receiver: IncomingRequestReceiver<ChunkFetchingRequest>,
    pub collation_req_receiver: IncomingRequestReceiver<CollationFetchingRequest>,
    pub available_data_req_receiver: IncomingRequestReceiver<AvailableDataFetchingRequest>,
    pub statement_req_receiver: IncomingRequestReceiver<StatementFetchingRequest>,
    pub dispute_req_receiver: IncomingRequestReceiver<DisputeRequest>,
    pub registry: Option<&'a Registry>,
    pub spawner: Spawner,
    pub is_collator: IsCollator,
    pub approval_voting_config: ApprovalVotingConfig,
    pub availability_config: AvailabilityConfig,
    pub candidate_validation_config: CandidateValidationConfig,
    pub chain_selection_config: ChainSelectionConfig,
    pub dispute_coordinator_config: DisputeCoordinatorConfig,
    pub pvf_checker_enabled: bool,
    pub overseer_message_channel_capacity_override: Option<usize>,
    pub req_protocol_names: ReqProtocolNames,
    pub peerset_protocol_names: PeerSetProtocolNames,
}

Expand description

Arguments passed for overseer construction.

Fields§

§leaves: Vec<BlockInfo>

Set of initial relay chain leaves to track.

§keystore: Arc<LocalKeystore>

The keystore to use for i.e. validator keys.

§runtime_client: Arc<RuntimeClient>

Runtime client generic, providing the ProvieRuntimeApi trait besides others.

§parachains_db: Arc<dyn Database>

The underlying key value store for the parachains.

§network_service: Arc<NetworkService<Block, Hash>>

Underlying network service implementation.

§authority_discovery_service: AuthorityDiscoveryService

Underlying authority discovery service.

§pov_req_receiver: IncomingRequestReceiver<PoVFetchingRequest>

POV request receiver

§chunk_req_receiver: IncomingRequestReceiver<ChunkFetchingRequest>§collation_req_receiver: IncomingRequestReceiver<CollationFetchingRequest>§available_data_req_receiver: IncomingRequestReceiver<AvailableDataFetchingRequest>§statement_req_receiver: IncomingRequestReceiver<StatementFetchingRequest>§dispute_req_receiver: IncomingRequestReceiver<DisputeRequest>§registry: Option<&'a Registry>

Prometheus registry, commonly used for production systems, less so for test.

§spawner: Spawner

Task spawner to be used throughout the overseer and the APIs it provides.

§is_collator: IsCollator

Determines the behavior of the collator.

§approval_voting_config: ApprovalVotingConfig

Configuration for the approval voting subsystem.

§availability_config: AvailabilityConfig

Configuration for the availability store subsystem.

§candidate_validation_config: CandidateValidationConfig

Configuration for the candidate validation subsystem.

§chain_selection_config: ChainSelectionConfig

Configuration for the chain selection subsystem.

§dispute_coordinator_config: DisputeCoordinatorConfig

Configuration for the dispute coordinator subsystem.

§pvf_checker_enabled: bool

Enable PVF pre-checking

§overseer_message_channel_capacity_override: Option<usize>

Overseer channel capacity override.

§req_protocol_names: ReqProtocolNames

Request-response protocol names source.

§peerset_protocol_names: PeerSetProtocolNames

[PeerSet] protocol names to protocols mapping.

Auto Trait Implementations§

§

impl<'a, Spawner, RuntimeClient> !RefUnwindSafe for OverseerGenArgs<'a, Spawner, RuntimeClient>

§

impl<'a, Spawner, RuntimeClient> Send for OverseerGenArgs<'a, Spawner, RuntimeClient>

§

impl<'a, Spawner, RuntimeClient> Sync for OverseerGenArgs<'a, Spawner, RuntimeClient>

§

Struct polkadot_service::overseer::OverseerGenArgs

Fields§

Auto Trait Implementations§

impl<'a, Spawner, RuntimeClient> !RefUnwindSafe for OverseerGenArgs<'a, Spawner, RuntimeClient>

impl<'a, Spawner, RuntimeClient> Send for OverseerGenArgs<'a, Spawner, RuntimeClient>

impl<'a, Spawner, RuntimeClient> Sync for OverseerGenArgs<'a, Spawner, RuntimeClient>

impl<'a, Spawner, RuntimeClient> Unpin for OverseerGenArgs<'a, Spawner, RuntimeClient>

impl<'a, Spawner, RuntimeClient> !UnwindSafe for OverseerGenArgs<'a, Spawner, RuntimeClient>

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> CheckedConversion for T

fn checked_from<T>(t: T) -> Option<Self>where Self: TryFrom<T>,

fn checked_into<T>(self) -> Option<T>where Self: TryInto<T>,

impl<T> Conv for T

fn conv<T>(self) -> Twhere Self: Into<T>,

impl<T> Downcast for Twhere T: Any,

fn into_any(self: Box<T, Global>) -> Box<dyn Any + 'static, Global>

fn into_any_rc(self: Rc<T>) -> Rc<dyn Any + 'static>

fn as_any(&self) -> &(dyn Any + 'static)

fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)

impl<T> DowncastSync for Twhere T: Any + Send + Sync,

fn into_any_arc(self: Arc<T>) -> Arc<dyn Any + Send + Sync + 'static>

impl<T> FmtForward for T

fn fmt_binary(self) -> FmtBinary<Self>where Self: Binary,

fn fmt_display(self) -> FmtDisplay<Self>where Self: Display,

fn fmt_lower_exp(self) -> FmtLowerExp<Self>where Self: LowerExp,

fn fmt_lower_hex(self) -> FmtLowerHex<Self>where Self: LowerHex,

fn fmt_octal(self) -> FmtOctal<Self>where Self: Octal,

fn fmt_pointer(self) -> FmtPointer<Self>where Self: Pointer,

fn fmt_upper_exp(self) -> FmtUpperExp<Self>where Self: UpperExp,

fn fmt_upper_hex(self) -> FmtUpperHex<Self>where Self: UpperHex,

fn fmt_list(self) -> FmtList<Self>where &'a Self: for<'a> IntoIterator,

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IsType<T> for T

fn from_ref(t: &T) -> &T

fn into_ref(&self) -> &T

fn from_mut(t: &mut T) -> &mut T

fn into_mut(&mut self) -> &mut T

impl<T, Outer> IsWrappedBy<Outer> for Twhere Outer: AsRef<T> + AsMut<T> + From<T>, T: From<Outer>,

fn from_ref(outer: &Outer) -> &T

fn from_mut(outer: &mut Outer) -> &mut T

impl<T> Pipe for Twhere T: ?Sized,

fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere Self: Sized,

fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere R: 'a,

fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere R: 'a,

fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> Rwhere Self: Borrow<B>, B: 'a + ?Sized, R: 'a,

fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R) -> Rwhere Self: BorrowMut<B>, B: 'a + ?Sized, R: 'a,

fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> Rwhere Self: AsRef<U>, U: 'a + ?Sized, R: 'a,

fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> Rwhere Self: AsMut<U>, U: 'a + ?Sized, R: 'a,

fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> Rwhere Self: Deref<Target = T>, T: 'a + ?Sized, R: 'a,

fn pipe_deref_mut<'a, T, R>(&'a mut self, func: impl FnOnce(&'a mut T) -> R) -> Rwhere Self: DerefMut<Target = T> + Deref, T: 'a + ?Sized, R: 'a,

impl<T> Pointable for T

const ALIGN: usize = mem::align_of::<T>()

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

impl<T> Same<T> for T

type Output = T

impl<T> SaturatedConversion for T

fn saturated_from<T>(t: T) -> Selfwhere Self: UniqueSaturatedFrom<T>,

fn saturated_into<T>(self) -> Twhere Self: UniqueSaturatedInto<T>,

impl<SS, SP> SupersetOf<SS> for SPwhere SS: SubsetOf<SP>,

fn to_subset(&self) -> Option<SS>

fn is_in_subset(&self) -> bool

impl<T> Any for Twhere
T: 'static + ?Sized,

impl<T> Borrow<T> for Twhere
T: ?Sized,

impl<T> BorrowMut<T> for Twhere
T: ?Sized,

fn checked_from<T>(t: T) -> Option<Self>where
Self: TryFrom<T>,

fn checked_into<T>(self) -> Option<T>where
Self: TryInto<T>,

fn conv<T>(self) -> Twhere
Self: Into<T>,

impl<T> Downcast for Twhere
T: Any,

impl<T> DowncastSync for Twhere
T: Any + Send + Sync,

fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,

fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,

fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,

fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,

fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,

fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,

fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,

fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,

fn fmt_list(self) -> FmtList<Self>where
&'a Self: for<'a> IntoIterator,

impl<T, U> Into<U> for Twhere
U: From<T>,

impl<T, Outer> IsWrappedBy<Outer> for Twhere
Outer: AsRef<T> + AsMut<T> + From<T>,
T: From<Outer>,

impl<T> Pipe for Twhere
T: ?Sized,

fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,

fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,

fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,

fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> Rwhere
Self: Borrow<B>,
B: 'a + ?Sized,
R: 'a,

fn pipe_borrow_mut<'a, B, R>(
&'a mut self,
func: impl FnOnce(&'a mut B) -> R
) -> Rwhere
Self: BorrowMut<B>,
B: 'a + ?Sized,
R: 'a,

fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> Rwhere
Self: AsRef<U>,
U: 'a + ?Sized,
R: 'a,

fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> Rwhere
Self: AsMut<U>,
U: 'a + ?Sized,
R: 'a,

fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> Rwhere
Self: Deref<Target = T>,
T: 'a + ?Sized,
R: 'a,

fn pipe_deref_mut<'a, T, R>(&'a mut self, func: impl FnOnce(&'a mut T) -> R) -> Rwhere
Self: DerefMut<Target = T> + Deref,
T: 'a + ?Sized,
R: 'a,

fn saturated_from<T>(t: T) -> Selfwhere
Self: UniqueSaturatedFrom<T>,

fn saturated_into<T>(self) -> Twhere
Self: UniqueSaturatedInto<T>,

impl<SS, SP> SupersetOf<SS> for SPwhere
SS: SubsetOf<SP>,

fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Selfwhere
Self: Borrow<B>,
B: ?Sized,

fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Selfwhere
Self: BorrowMut<B>,
B: ?Sized,

fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Selfwhere
Self: AsRef<R>,
R: ?Sized,

fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Selfwhere
Self: AsMut<R>,
R: ?Sized,

fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Selfwhere
Self: Deref<Target = T>,
T: ?Sized,

fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Selfwhere
Self: DerefMut<Target = T> + Deref,
T: ?Sized,

fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Selfwhere
Self: Borrow<B>,
B: ?Sized,

fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Selfwhere
Self: BorrowMut<B>,
B: ?Sized,

fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Selfwhere
Self: AsRef<R>,
R: ?Sized,

fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Selfwhere
Self: AsMut<R>,
R: ?Sized,

fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Selfwhere
Self: Deref<Target = T>,
T: ?Sized,

fn tap_deref_mut_dbg<T>(self, func: impl FnOnce(&mut T)) -> Selfwhere
Self: DerefMut<Target = T> + Deref,
T: ?Sized,

fn try_conv<T>(self) -> Result<T, Self::Error>where
Self: TryInto<T>,

impl<T, U> TryFrom<U> for Twhere
U: Into<T>,

impl<T, U> TryInto<U> for Twhere
U: TryFrom<T>,

impl<S, T> UncheckedInto<T> for Swhere
T: UncheckedFrom<S>,

impl<T, S> UniqueSaturatedInto<T> for Swhere
T: Bounded,
S: TryInto<T>,

impl<V, T> VZip<V> for Twhere
V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where
S: Into<Dispatch>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where
S: Into<Dispatch>,

impl<T> MaybeSend for Twhere
T: Send,