Struct modality_ingest_client::client::IngestClient

pub struct IngestClient<S> { /* private fields */ }

Implementations

impl IngestClient<UnauthenticatedState>

pub async fn connect( endpoint: &Url, allow_insecure_tls: bool, ) -> Result<IngestClient<UnauthenticatedState>, IngestClientInitializationError>

Create a new ingest client.

pub async fn authenticate( self, token: Vec<u8>, ) -> Result<IngestClient<ReadyState>, IngestError>

impl IngestClient<ReadyState>

pub async fn open_timeline( self, id: TimelineId, ) -> Result<IngestClient<BoundTimelineState>, IngestError>

pub async fn attr_key( &mut self, key_name: String, ) -> Result<AttrKey, IngestError>

impl IngestClient<BoundTimelineState>

pub fn bound_timeline(&self) -> TimelineId

pub async fn open_timeline(&mut self, id: TimelineId) -> Result<(), IngestError>

pub fn close_timeline(self) -> IngestClient<ReadyState>

This doesn’t change the connection state, but it does require you to open_timeline again before you can do anything else.

pub async fn attr_key( &mut self, key_name: String, ) -> Result<AttrKey, IngestError>

pub async fn timeline_metadata( &mut self, attrs: impl IntoIterator<Item = (AttrKey, AttrVal)>, ) -> Result<(), IngestError>

pub async fn event( &mut self, ordering: u128, attrs: impl IntoIterator<Item = (AttrKey, AttrVal)>, ) -> Result<(), IngestError>

pub async fn flush(&mut self) -> Result<(), IngestError>

pub async fn status(&mut self) -> Result<IngestStatus, IngestError>