Struct State

pub struct State<T>(/* private fields */);

Worker state that persists across job auto handler invocations.

Examples

use futures::future;
use serde::Serialize;
use std::cell::Cell;
use thiserror::Error;
use zeebe::{Client, State};

#[derive(Error, Debug)]
enum MyError {}

#[derive(Serialize)]
struct MyJobResult {
    result: u32,
}

struct MyJobState {
    total: Cell<u32>,
}

let client = Client::default();

let job_state = MyJobState {
    total: Cell::new(0),
};

let _job = client
    .job_worker()
    .with_job_type("my-job-type")
    .with_auto_handler(|my_job_state: State<MyJobState>| {
        future::ok::<_, MyError>(MyJobResult { result: 42 })
    })
    .with_state(job_state)
    .run()
    .await?;

Implementations

impl<T> State<T>

pub fn new(state: T) -> State<T>

Create new State instance.

pub fn get_ref(&self) -> &T

Get reference to inner app data.

pub fn into_inner(self) -> Arc<T>

Convert to the internal Arc

Trait Implementations

impl<T> Clone for State<T>

fn clone(&self) -> State<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T> Debug for State<T>

where T: Debug,

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

Formats the value using the given formatter.

impl<T> Deref for State<T>

type Target = Arc<T>

The resulting type after dereferencing.

fn deref(&self) -> &Arc<T>

Dereferences the value.

impl<T> Display for State<T>

where T: Display,

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

Formats the value using the given formatter.

impl<T> From<Arc<T>> for State<T>

fn from(arc: Arc<T>) -> Self

Converts to this type from the input type.