Struct fuel_core::service::Task

pub struct Task {
    pub shared: SharedState,
    /* private fields */
}

Fields

shared: SharedState

The address bound by the system for serving the API

Implementations

impl Task

pub fn new(database: Database, config: Config) -> Result<Task>

Private inner method for initializing the fuel service task

Trait Implementations

impl RunnableService for Task

const NAME: &'static str = "FuelService"

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

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 RunnableTask for Task

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.