Struct TurboTasksBackend 

pub struct TurboTasksBackend<B: BackingStorage>(/* private fields */);

Implementations

impl<B: BackingStorage> TurboTasksBackend<B>

pub fn new(options: BackendOptions, backing_storage: B) -> Self

pub fn backing_storage(&self) -> &B

Trait Implementations

impl<B: BackingStorage> Backend for TurboTasksBackend<B>

type BackendJob = TurboTasksBackendJob

fn startup(&self, turbo_tasks: &dyn TurboTasksBackendApi<Self>)

fn stopping(&self, _turbo_tasks: &dyn TurboTasksBackendApi<Self>)

fn stop(&self, turbo_tasks: &dyn TurboTasksBackendApi<Self>)

fn idle_start(&self, turbo_tasks: &dyn TurboTasksBackendApi<Self>)

fn idle_end(&self, _turbo_tasks: &dyn TurboTasksBackendApi<Self>)

fn get_or_create_persistent_task( &self, task_type: CachedTaskType, parent_task: Option<TaskId>, turbo_tasks: &dyn TurboTasksBackendApi<Self>, ) -> TaskId

fn get_or_create_transient_task( &self, task_type: CachedTaskType, parent_task: Option<TaskId>, turbo_tasks: &dyn TurboTasksBackendApi<Self>, ) -> TaskId

fn invalidate_task( &self, task_id: TaskId, turbo_tasks: &dyn TurboTasksBackendApi<Self>, )

fn invalidate_tasks( &self, tasks: &[TaskId], turbo_tasks: &dyn TurboTasksBackendApi<Self>, )

fn invalidate_tasks_set( &self, tasks: &AutoSet<TaskId, BuildHasherDefault<FxHasher>, 2>, turbo_tasks: &dyn TurboTasksBackendApi<Self>, )

fn invalidate_serialization( &self, task_id: TaskId, turbo_tasks: &dyn TurboTasksBackendApi<Self>, )

fn task_execution_canceled( &self, task: TaskId, turbo_tasks: &dyn TurboTasksBackendApi<Self>, )

fn try_start_task_execution( &self, task_id: TaskId, priority: TaskPriority, turbo_tasks: &dyn TurboTasksBackendApi<Self>, ) -> Option<TaskExecutionSpec<'_>>

fn task_execution_completed( &self, task_id: TaskId, result: Result<RawVc, TurboTasksExecutionError>, cell_counters: &AutoMap<ValueTypeId, u32, BuildHasherDefault<FxHasher>, 8>, has_invalidator: bool, turbo_tasks: &dyn TurboTasksBackendApi<Self>, ) -> bool

fn run_backend_job<'a>( &'a self, job: Self::BackendJob, turbo_tasks: &'a dyn TurboTasksBackendApi<Self>, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'a>>

fn try_read_task_output( &self, task_id: TaskId, reader: Option<TaskId>, options: ReadOutputOptions, turbo_tasks: &dyn TurboTasksBackendApi<Self>, ) -> Result<Result<RawVc, EventListener>>

INVALIDATION: Be careful with this, when reader is None, it will not track dependencies, so using it could break cache invalidation.

fn try_read_task_cell( &self, task_id: TaskId, cell: CellId, reader: Option<TaskId>, options: ReadCellOptions, turbo_tasks: &dyn TurboTasksBackendApi<Self>, ) -> Result<Result<TypedCellContent, EventListener>>

INVALIDATION: Be careful with this, when reader is None, it will not track dependencies, so using it could break cache invalidation.

fn try_read_own_task_cell( &self, task_id: TaskId, cell: CellId, options: ReadCellOptions, turbo_tasks: &dyn TurboTasksBackendApi<Self>, ) -> Result<TypedCellContent>

INVALIDATION: Be careful with this, it will not track dependencies, so using it could break cache invalidation.

fn read_task_collectibles( &self, task_id: TaskId, collectible_type: TraitTypeId, reader: Option<TaskId>, turbo_tasks: &dyn TurboTasksBackendApi<Self>, ) -> AutoMap<RawVc, i32, BuildHasherDefault<FxHasher>, 1>

INVALIDATION: Be careful with this, when reader is None, it will not track dependencies, so using it could break cache invalidation.

fn emit_collectible( &self, collectible_type: TraitTypeId, collectible: RawVc, task_id: TaskId, turbo_tasks: &dyn TurboTasksBackendApi<Self>, )

fn unemit_collectible( &self, collectible_type: TraitTypeId, collectible: RawVc, count: u32, task_id: TaskId, turbo_tasks: &dyn TurboTasksBackendApi<Self>, )

fn update_task_cell( &self, task_id: TaskId, cell: CellId, is_serializable_cell_content: bool, content: CellContent, updated_key_hashes: Option<SmallVec<[u64; 2]>>, verification_mode: VerificationMode, turbo_tasks: &dyn TurboTasksBackendApi<Self>, )

fn mark_own_task_as_finished( &self, task_id: TaskId, turbo_tasks: &dyn TurboTasksBackendApi<Self>, )

fn mark_own_task_as_session_dependent( &self, task: TaskId, turbo_tasks: &dyn TurboTasksBackendApi<Self>, )

fn connect_task( &self, task: TaskId, parent_task: Option<TaskId>, turbo_tasks: &dyn TurboTasksBackendApi<Self>, )

fn create_transient_task( &self, task_type: TransientTaskType, _turbo_tasks: &dyn TurboTasksBackendApi<Self>, ) -> TaskId

fn dispose_root_task( &self, task_id: TaskId, turbo_tasks: &dyn TurboTasksBackendApi<Self>, )

fn task_statistics(&self) -> &TaskStatisticsApi

fn is_tracking_dependencies(&self) -> bool

fn get_task_name( &self, task: TaskId, turbo_tasks: &dyn TurboTasksBackendApi<Self>, ) -> String

Returns a human-readable name for the given task. Used by error display formatting to lazily resolve task names instead of storing them eagerly in error objects.