Struct fuel_core_p2p::service::Task

pub struct Task<D> { /* private fields */ }

Orchestrates various p2p-related events between the inner P2pService and the top level NetworkService.

Implementations

impl<D> Task<D>

pub fn new<B: BlockHeightImporter>( config: Config, db: Arc<D>, block_importer: Arc<B> ) -> Self

Trait Implementations

impl<D> RunnableService for Task<D>where Self: RunnableTask,

const NAME: &'static str = "P2P"

The name of the runnable service, used for namespacing error messages.

type SharedData = SharedState

Service specific shared data. This is used when you have data that needs to be shared by one or more tasks. It is the implementors responsibility to ensure cloning this type is shallow and doesn’t provide a full duplication of data that is meant to be shared between asynchronous processes.

type Task = Task<D>

The initialized runnable task type.

fn shared_data(&self) -> Self::SharedData

A cloned instance of the shared data

fn into_task<'life0, 'async_trait>( self, _: &'life0 StateWatcher ) -> Pin<Box<dyn Future<Output = Result<Self::Task>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Converts the service into a runnable task before the main run loop.

impl<D> RunnableTask for Task<D>where D: P2pDb + 'static,

fn run<'life0, 'life1, 'async_trait>( &'life0 mut self, watcher: &'life1 mut StateWatcher ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

This function should contain the main business logic of the service task. It will run until the service either returns false, panics or a stop signal is received. If the service returns an error, it will be logged and execution will resume. This is intended to be called only by the ServiceRunner.

fn shutdown<'async_trait>( self ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where Self: 'async_trait,

Gracefully shutdowns the task after the end of the execution cycle.