pub trait JournalHandler {
Show 19 methods
// Required methods
fn message_dispatched(
&mut self,
message_id: MessageId,
source: ActorId,
outcome: DispatchOutcome,
);
fn gas_burned(&mut self, message_id: MessageId, amount: u64);
fn exit_dispatch(&mut self, id_exited: ActorId, value_destination: ActorId);
fn message_consumed(&mut self, message_id: MessageId);
fn send_dispatch(
&mut self,
message_id: MessageId,
dispatch: Dispatch,
delay: u32,
reservation: Option<ReservationId>,
);
fn wait_dispatch(
&mut self,
dispatch: StoredDispatch,
duration: Option<u32>,
waited_type: MessageWaitedType,
);
fn wake_message(
&mut self,
message_id: MessageId,
program_id: ActorId,
awakening_id: MessageId,
delay: u32,
);
fn update_pages_data(
&mut self,
program_id: ActorId,
pages_data: BTreeMap<GearPage, PageBuf>,
);
fn update_allocations(
&mut self,
program_id: ActorId,
allocations: IntervalsTree<WasmPage>,
);
fn send_value(
&mut self,
from: ActorId,
to: ActorId,
value: u128,
locked: bool,
);
fn store_new_programs(
&mut self,
program_id: ActorId,
code_id: CodeId,
candidates: Vec<(MessageId, ActorId)>,
);
fn stop_processing(&mut self, dispatch: StoredDispatch, gas_burned: u64);
fn reserve_gas(
&mut self,
message_id: MessageId,
reservation_id: ReservationId,
program_id: ActorId,
amount: u64,
bn: u32,
);
fn unreserve_gas(
&mut self,
reservation_id: ReservationId,
program_id: ActorId,
expiration: u32,
);
fn update_gas_reservation(
&mut self,
program_id: ActorId,
reserver: GasReserver,
);
fn system_reserve_gas(&mut self, message_id: MessageId, amount: u64);
fn system_unreserve_gas(&mut self, message_id: MessageId);
fn send_signal(
&mut self,
message_id: MessageId,
destination: ActorId,
code: SignalCode,
);
fn reply_deposit(
&mut self,
message_id: MessageId,
future_reply_id: MessageId,
amount: u64,
);
}Expand description
Journal handler.
Something that can update state.
Required Methods§
Sourcefn message_dispatched(
&mut self,
message_id: MessageId,
source: ActorId,
outcome: DispatchOutcome,
)
fn message_dispatched( &mut self, message_id: MessageId, source: ActorId, outcome: DispatchOutcome, )
Process message dispatch.
Sourcefn gas_burned(&mut self, message_id: MessageId, amount: u64)
fn gas_burned(&mut self, message_id: MessageId, amount: u64)
Process gas burned.
Sourcefn exit_dispatch(&mut self, id_exited: ActorId, value_destination: ActorId)
fn exit_dispatch(&mut self, id_exited: ActorId, value_destination: ActorId)
Process exit dispatch.
Sourcefn message_consumed(&mut self, message_id: MessageId)
fn message_consumed(&mut self, message_id: MessageId)
Process message consumed.
Sourcefn send_dispatch(
&mut self,
message_id: MessageId,
dispatch: Dispatch,
delay: u32,
reservation: Option<ReservationId>,
)
fn send_dispatch( &mut self, message_id: MessageId, dispatch: Dispatch, delay: u32, reservation: Option<ReservationId>, )
Process send dispatch.
Sourcefn wait_dispatch(
&mut self,
dispatch: StoredDispatch,
duration: Option<u32>,
waited_type: MessageWaitedType,
)
fn wait_dispatch( &mut self, dispatch: StoredDispatch, duration: Option<u32>, waited_type: MessageWaitedType, )
Process send message.
Sourcefn wake_message(
&mut self,
message_id: MessageId,
program_id: ActorId,
awakening_id: MessageId,
delay: u32,
)
fn wake_message( &mut self, message_id: MessageId, program_id: ActorId, awakening_id: MessageId, delay: u32, )
Process send message.
Sourcefn update_pages_data(
&mut self,
program_id: ActorId,
pages_data: BTreeMap<GearPage, PageBuf>,
)
fn update_pages_data( &mut self, program_id: ActorId, pages_data: BTreeMap<GearPage, PageBuf>, )
Process page update.
Sourcefn update_allocations(
&mut self,
program_id: ActorId,
allocations: IntervalsTree<WasmPage>,
)
fn update_allocations( &mut self, program_id: ActorId, allocations: IntervalsTree<WasmPage>, )
Process JournalNote::UpdateAllocations.
Sourcefn store_new_programs(
&mut self,
program_id: ActorId,
code_id: CodeId,
candidates: Vec<(MessageId, ActorId)>,
)
fn store_new_programs( &mut self, program_id: ActorId, code_id: CodeId, candidates: Vec<(MessageId, ActorId)>, )
Store new programs in storage.
Program ids are ids of potential (planned to be initialized) programs.
Sourcefn stop_processing(&mut self, dispatch: StoredDispatch, gas_burned: u64)
fn stop_processing(&mut self, dispatch: StoredDispatch, gas_burned: u64)
Stop processing queue.
Pushes StoredDispatch back to the top of the queue and decreases gas allowance.
Sourcefn reserve_gas(
&mut self,
message_id: MessageId,
reservation_id: ReservationId,
program_id: ActorId,
amount: u64,
bn: u32,
)
fn reserve_gas( &mut self, message_id: MessageId, reservation_id: ReservationId, program_id: ActorId, amount: u64, bn: u32, )
Reserve gas.
Sourcefn unreserve_gas(
&mut self,
reservation_id: ReservationId,
program_id: ActorId,
expiration: u32,
)
fn unreserve_gas( &mut self, reservation_id: ReservationId, program_id: ActorId, expiration: u32, )
Unreserve gas.
Sourcefn update_gas_reservation(&mut self, program_id: ActorId, reserver: GasReserver)
fn update_gas_reservation(&mut self, program_id: ActorId, reserver: GasReserver)
Update gas reservations.
Sourcefn system_reserve_gas(&mut self, message_id: MessageId, amount: u64)
fn system_reserve_gas(&mut self, message_id: MessageId, amount: u64)
Do system reservation.
Sourcefn system_unreserve_gas(&mut self, message_id: MessageId)
fn system_unreserve_gas(&mut self, message_id: MessageId)
Do system unreservation.
Sourcefn send_signal(
&mut self,
message_id: MessageId,
destination: ActorId,
code: SignalCode,
)
fn send_signal( &mut self, message_id: MessageId, destination: ActorId, code: SignalCode, )
Send system signal.
Sourcefn reply_deposit(
&mut self,
message_id: MessageId,
future_reply_id: MessageId,
amount: u64,
)
fn reply_deposit( &mut self, message_id: MessageId, future_reply_id: MessageId, amount: u64, )
Create deposit for future reply.