Struct deno_kv::Enqueue

source ·

pub struct Enqueue {
    pub payload: Vec<u8>,
    pub deadline_ms: u64,
    pub keys_if_undelivered: Vec<Vec<u8>>,
    pub backoff_schedule: Option<Vec<u32>>,
}

Expand description

A request to enqueue a message to the database. This message is delivered to a listener of the queue at least once.

Retry

When the delivery of a message fails, it is retried for a finite number of times. Each retry happens after a backoff period. The backoff periods are specified by the backoff_schedule field in milliseconds. If unspecified, the default backoff schedule of the platform (CLI or Deploy) is used.

If all retry attempts failed, the message is written to the KV under all keys specified in keys_if_undelivered.

Fields§

§payload: Vec<u8>§deadline_ms: u64§keys_if_undelivered: Vec<Vec<u8>>§backoff_schedule: Option<Vec<u32>>

Struct deno_kv::Enqueue

Retry

Fields§

Trait Implementations§

impl TryFrom<(ZeroCopyBuf, u64, Vec<Vec<AnyValue, Global>, Global>, Option<Vec<u32, Global>>)> for Enqueue

type Error = Error

fn try_from( value: (ZeroCopyBuf, u64, Vec<Vec<AnyValue>>, Option<Vec<u32>>) ) -> Result<Self, AnyError>

Auto Trait Implementations§

impl RefUnwindSafe for Enqueue

impl Send for Enqueue

impl Sync for Enqueue

impl Unpin for Enqueue

impl UnwindSafe for Enqueue

Blanket Implementations§

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

fn type_id(&self) -> TypeId

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

fn borrow(&self) -> &T

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

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

impl<T> From<T> for T

fn from(t: T) -> T

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

fn into(self) -> U

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

type Error = Infallible

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

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

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

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