Struct DynamicIngestClient

pub struct DynamicIngestClient { /* private fields */ }

A more dynamic ingest client, for places where the session types are difficult to use.

Implementations

impl DynamicIngestClient

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

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

pub fn close_timeline(&mut self)

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

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

Trait Implementations

impl From<IngestClient<BoundTimelineState>> for DynamicIngestClient

fn from(c: IngestClient<BoundTimelineState>) -> Self

Converts to this type from the input type.

impl From<IngestClient<ReadyState>> for DynamicIngestClient

fn from(c: IngestClient<ReadyState>) -> Self

Converts to this type from the input type.