Struct modality_ingest_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 declare_attr_key(
    &mut self,
    key_name: String
) -> Result<InternedAttrKey, 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 declare_attr_key(
    &mut self,
    key_name: String
) -> Result<InternedAttrKey, IngestError>

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

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

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

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