Struct UnionListState 

pub struct UnionListState { /* private fields */ }

Union list state (list that is distributed across parallel instances).

Implementations

impl UnionListState

pub fn new() -> Self

Create a new union list state.

pub async fn get(&self) -> Vec<Vec<u8>>

Get all values.

pub async fn add(&self, value: Vec<u8>)

Add a value.

pub async fn add_all(&self, values: Vec<Vec<u8>>)

Add multiple values.

pub async fn update(&self, values: Vec<Vec<u8>>)

Update with new values.

pub async fn clear(&self)

Clear all values.

pub async fn len(&self) -> usize

Get the number of values.

pub async fn is_empty(&self) -> bool

Check if empty.

Trait Implementations

impl Default for UnionListState

fn default() -> Self

Returns the “default value” for a type.

impl OperatorState for UnionListState

async fn snapshot(&self) -> Result<Vec<u8>>

Snapshot the state.

async fn restore(&self, snapshot: &[u8]) -> Result<()>

Restore from a snapshot.