Struct AsyncNominalChannelWriterServiceClient 

pub struct AsyncNominalChannelWriterServiceClient<C> { /* private fields */ }

Trait Implementations

impl<O, I: Stream<Item = Result<Bytes, Error>>, __C> AsyncNominalChannelWriterService<O, I> for AsyncNominalChannelWriterServiceClient<__C>

where __C: AsyncClient<BodyWriter = O, ResponseBody = I> + Sync + Send, __C::ResponseBody: 'static + Send,

async fn write_batches( &self, auth_: &BearerToken, request: &WriteBatchesRequestExternal, ) -> Result<(), Error>

Synchronously writes batches of records to a Nominal data source.

async fn write_column_batches( &self, auth_: &BearerToken, request: &WriteColumnBatchesRequest, ) -> Result<(), Error>

Synchronously writes batches of columns of data to a Nominal data source.

async fn write_telegraf_batches( &self, auth_: &BearerToken, data_source_rid: &NominalDataSourceOrDatasetRid, request: &WriteTelegrafBatchesRequest, ) -> Result<(), Error>

Synchronously writes batches of records to a Nominal data source.

async fn write_prometheus_batches( &self, auth_: &BearerToken, data_source_rid: &NominalDataSourceOrDatasetRid, request: impl AsyncWriteBody<O> + Sync + Send, ) -> Result<(), Error>

Synchronously writes batches of records to a Nominal data source.

async fn prometheus_remote_write_health_check( &self, auth_: &BearerToken, data_source_rid: &NominalDataSourceOrDatasetRid, ) -> Result<bool, Error>

Performs a health check for prometheus remote write Vector sink. All this endpoint does is verify if the caller is authenticated and the server is online. Once Vector allows the Prometheus remote write endpoint to configure the healthcheck url, we can remove this endpoint.

async fn write_nominal_batches( &self, auth_: &BearerToken, data_source_rid: &NominalDataSourceOrDatasetRid, request: impl AsyncWriteBody<O> + Sync + Send, ) -> Result<(), Error>

Synchronously writes a Nominal Write Request to a Nominal data source using the NominalWrite Protobuf schema. The request must be Protobuf-encoded and accompanied by the appropriate content encoding headers if compressed.

async fn write_nominal_columnar_batches( &self, auth_: &BearerToken, request: impl AsyncWriteBody<O> + Sync + Send, ) -> Result<(), Error>

Synchronously writes to a Nominal data source using the columnar WriteBatchesRequest Protobuf schema.

async fn write_logs( &self, auth_: &BearerToken, data_source_rid: &NominalDataSourceOrDatasetRid, request: &WriteLogsRequest, ) -> Result<(), Error>

Synchronously writes logs to a Nominal data source.

impl<C> AsyncService<C> for AsyncNominalChannelWriterServiceClient<C>

fn new(client: C, runtime: &Arc<ConjureRuntime>) -> Self

Creates a new service wrapping an async HTTP client.

impl<C: Clone> Clone for AsyncNominalChannelWriterServiceClient<C>

fn clone(&self) -> AsyncNominalChannelWriterServiceClient<C>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<C: Debug> Debug for AsyncNominalChannelWriterServiceClient<C>

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

Formats the value using the given formatter.