Struct BroadcastState 

pub struct BroadcastState { /* private fields */ }

Broadcast state (shared across all parallel instances).

Implementations

impl BroadcastState

pub fn new() -> Self

Create a new broadcast state.

pub async fn get(&self, key: &[u8]) -> Option<Vec<u8>>

Get a value.

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

Put a value.

pub async fn remove(&self, key: &[u8])

Remove a value.

pub async fn contains(&self, key: &[u8]) -> bool

Check if a key exists.

pub async fn clear(&self)

Clear all state.

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

Get all keys.

Trait Implementations

impl Default for BroadcastState

fn default() -> Self

Returns the “default value” for a type.

impl OperatorState for BroadcastState

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

Snapshot the state.

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

Restore from a snapshot.