Struct DurableService 

pub struct DurableService { /* private fields */ }

Implementations

impl DurableService

pub fn new<T>(inner: T) -> Self

where T: Durable + 'static,

pub fn downcast_ref<T: Durable>(&self) -> Option<&T>

pub async fn save( &self, topic: TopicCode, message: DurableMessage, ) -> Result<(), DurableError>

pub async fn update_status( &self, topic: TopicCode, update: MessageStateUpdate, ) -> Result<(), DurableError>

pub async fn archive( &self, topic: TopicCode, message_id: MessageId, ) -> Result<(), DurableError>

pub async fn retrieve( &self, topic: TopicCode, message_id: MessageId, ) -> Result<DurableMessage, DurableError>

pub async fn batch_retrieve( &self, topic: TopicCode, query: DurableMessageQuery, ) -> Result<Vec<DurableMessage>, DurableError>

pub async fn create_topic(&self, topic: TopicConfig) -> Result<(), DurableError>

pub async fn delete_topic(&self, topic: TopicCode) -> Result<(), DurableError>

pub async fn topic_code_list(&self) -> Result<Vec<TopicCode>, DurableError>

pub async fn topic_list(&self) -> Result<Vec<TopicConfig>, DurableError>

Trait Implementations

impl Clone for DurableService

fn clone(&self) -> DurableService

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DurableService

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

Formats the value using the given formatter.