Struct execution_definitions::activation::NandoActivation

pub struct NandoActivation {

    pub activation_id: ActivationId,
    pub activation_intent: NandoActivationIntent,
    pub activation_log_entry: Arc<RefCell<TransactionLogEntry>>,
    pub handle_state: Option<SharedHandleState>,
    pub executor: usize,
    resolved_args: RefCell<Vec<ResolvedNandoArgument>>,
    target: Arc<ActivationFunction>,
    pub meta: NandoMetadata,
    pub epic_information: ActivationEpicInformation,
    pub ecb: EpicTaskInfo,
    pub status: TransactionStatus,
    pub execution_error: Option<ExecutionError>,
    pub mv_updates: RefCell<Vec<(ObjectId, bool)>>,
}

Fields

activation_id: ActivationId

activation_intent: NandoActivationIntent

activation_log_entry: Arc<RefCell<TransactionLogEntry>>

handle_state: Option<SharedHandleState>

executor: usize

resolved_args: RefCell<Vec<ResolvedNandoArgument>>

target: Arc<ActivationFunction>

meta: NandoMetadata

epic_information: ActivationEpicInformation

ecb: EpicTaskInfo

status: TransactionStatus

execution_error: Option<ExecutionError>

mv_updates: RefCell<Vec<(ObjectId, bool)>>

Implementations

impl NandoActivation

pub fn new( activation_intent: NandoActivationIntent, txn_id: TxnId, handle_state: Option<SharedHandleState>, nando_closure: Arc<ActivationFunction>, meta: NandoMetadata ) -> Self

pub fn from_intent( intent: NandoActivationIntent, activation_id: ActivationId, nando_closure: Arc<ActivationFunction>, meta: NandoMetadata ) -> Self

pub fn set_top_level(&mut self)

pub fn set_non_top_level(&mut self)

pub fn handle_is_dummy(&self) -> bool

pub fn get_result(&self) -> ActivationOutput

pub fn get_object_references(&self) -> Vec<ObjectId>

pub fn mark_done_and_wake(&self)

pub fn mark_triggered_and_wake(&self)

pub fn mark_failed_and_wake(&self)

pub fn set_handle_state(&mut self, handle_state: SharedHandleState)

pub fn get_handle_state(&self) -> Option<SharedHandleState>

pub fn resolve_intent_arg(&mut self, idx: usize, resolved_arg: NandoArgument)

pub fn call(&self, object_tracker: Arc<ObjectTracker>)

pub fn get_resolved_args(&self) -> &RefCell<Vec<ResolvedNandoArgument>>

pub fn get_resolved_object_arg_mappings(&self) -> Vec<ObjectMapping>

pub fn is_part_of_epic(&self) -> bool

pub fn set_ecb(&mut self, ecb: ECB)

pub fn get_ecb(&self) -> Option<Arc<RefCell<ECB>>>

pub fn set_top_level_ecb(&mut self, host_idx: u64)

pub fn set_ecb_from_dependency_info(self) -> Self

pub fn set_task_control_info(&mut self, task_control_info: SpawnedTask)

pub fn get_task_control_info(&self) -> Option<SpawnedTask>

pub fn get_task_control_id(&self) -> Option<EcbId>

pub fn is_top_level(&self) -> bool

pub fn set_status_done(&mut self)

pub fn set_status_failed(&mut self, err: ExecutionError)

pub fn is_pending(&self) -> bool

pub fn is_failed(&self) -> bool

pub fn add_mv_update(&self, object_id: ObjectId, mv_enabled: bool)

pub fn get_object_arg_at_idx(&self, arg_idx: usize) -> Option<ObjectId>

pub fn get_object_args_at_idx(&self, arg_idx: usize) -> Vec<ObjectId>

pub fn get_args_as_intent_args(&self) -> Vec<NandoArgument>

Trait Implementations

impl Debug for NandoActivation

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Send for NandoActivation