OplogEntry

Enum OplogEntry 

Source
pub enum OplogEntry {
Show 32 variants Create(CreateParameters), ImportedFunctionInvoked(ImportedFunctionInvokedParameters), ExportedFunctionInvoked(ExportedFunctionInvokedParameters), ExportedFunctionCompleted(ExportedFunctionCompletedParameters), Suspend(Datetime), Error(ErrorParameters), NoOp(Datetime), Jump(JumpParameters), Interrupted(Datetime), Exited(Datetime), ChangeRetryPolicy(ChangeRetryPolicyParameters), BeginAtomicRegion(Datetime), EndAtomicRegion(EndAtomicRegionParameters), BeginRemoteWrite(Datetime), EndRemoteWrite(EndRemoteWriteParameters), PendingWorkerInvocation(PendingWorkerInvocationParameters), PendingUpdate(PendingUpdateParameters), SuccessfulUpdate(SuccessfulUpdateParameters), FailedUpdate(FailedUpdateParameters), GrowMemory(GrowMemoryParameters), CreateResource(CreateResourceParameters), DropResource(DropResourceParameters), Log(LogParameters), Restart(Datetime), ActivatePlugin(ActivatePluginParameters), DeactivatePlugin(DeactivatePluginParameters), Revert(RevertParameters), CancelInvocation(CancelInvocationParameters), StartSpan(StartSpanParameters), FinishSpan(FinishSpanParameters), SetSpanAttribute(SetSpanAttributeParameters), ChangePersistenceLevel(ChangePersistenceLevelParameters),
}

Variants§

§

Create(CreateParameters)

The initial worker oplog entry

§

ImportedFunctionInvoked(ImportedFunctionInvokedParameters)

The worker invoked a host function

§

ExportedFunctionInvoked(ExportedFunctionInvokedParameters)

The worker has been invoked

§

ExportedFunctionCompleted(ExportedFunctionCompletedParameters)

The worker has completed an invocation

§

Suspend(Datetime)

Worker suspended

§

Error(ErrorParameters)

Worker failed

§

NoOp(Datetime)

Marker entry added when get-oplog-index is called from the worker, to make the jumping behavior more predictable.

§

Jump(JumpParameters)

The worker needs to recover up to the given target oplog index and continue running from the source oplog index from there jump is an oplog region representing that from the end of that region we want to go back to the start and ignore all recorded operations in between.

§

Interrupted(Datetime)

Indicates that the worker has been interrupted at this point. Only used to recompute the worker’s (cached) status, has no effect on execution.

§

Exited(Datetime)

Indicates that the worker has been exited using WASI’s exit function.

§

ChangeRetryPolicy(ChangeRetryPolicyParameters)

Overrides the worker’s retry policy

§

BeginAtomicRegion(Datetime)

Begins an atomic region. All oplog entries after BeginAtomicRegion are to be ignored during recovery except if there is a corresponding EndAtomicRegion entry.

§

EndAtomicRegion(EndAtomicRegionParameters)

Ends an atomic region. All oplog entries between the corresponding BeginAtomicRegion and this entry are to be considered during recovery, and the begin/end markers can be removed during oplog compaction.

§

BeginRemoteWrite(Datetime)

Begins a remote write operation. Only used when idempotence mode is off. In this case each remote write must be surrounded by a BeginRemoteWrite and EndRemoteWrite log pair and unfinished remote writes cannot be recovered.

§

EndRemoteWrite(EndRemoteWriteParameters)

Marks the end of a remote write operation. Only used when idempotence mode is off.

§

PendingWorkerInvocation(PendingWorkerInvocationParameters)

An invocation request arrived while the worker was busy

§

PendingUpdate(PendingUpdateParameters)

An update request arrived and will be applied as soon the worker restarts

§

SuccessfulUpdate(SuccessfulUpdateParameters)

An update was successfully applied

§

FailedUpdate(FailedUpdateParameters)

An update failed to be applied

§

GrowMemory(GrowMemoryParameters)

Increased total linear memory size

§

CreateResource(CreateResourceParameters)

Created a resource instance

§

DropResource(DropResourceParameters)

Dropped a resource instance

§

Log(LogParameters)

The worker emitted a log message

§

Restart(Datetime)

The worker’s has been restarted, forgetting all its history

§

ActivatePlugin(ActivatePluginParameters)

Activates a plugin

§

DeactivatePlugin(DeactivatePluginParameters)

Deactivates a plugin

§

Revert(RevertParameters)

Revert a worker to a previous state

§

CancelInvocation(CancelInvocationParameters)

Cancel a pending invocation

§

StartSpan(StartSpanParameters)

Start a new span in the invocation context

§

FinishSpan(FinishSpanParameters)

Finish an open span in the invocation context

§

SetSpanAttribute(SetSpanAttributeParameters)

Set an attribute on an open span in the invocation context

§

ChangePersistenceLevel(ChangePersistenceLevelParameters)

Change the current persistence level

Trait Implementations§

Source§

impl Clone for OplogEntry

Source§

fn clone(&self) -> OplogEntry

Returns a duplicate of the value. Read more
1.0.0 · Source§

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source. Read more
Source§

impl Debug for OplogEntry

Source§

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> TupleOrUnit<()> for T

Source§

fn into(self)