Struct NominalChannelWriterServiceClient 

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

Trait Implementations

impl<C: Clone> Clone for NominalChannelWriterServiceClient<C>

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<C: Debug> Debug for NominalChannelWriterServiceClient<C>

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

Formats the value using the given formatter.

impl<O, I: Iterator<Item = Result<Bytes, Error>>, __C> NominalChannelWriterService<O, I> for NominalChannelWriterServiceClient<__C>

where __C: Client<BodyWriter = O, ResponseBody = I>,

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

Synchronously writes batches of records to a Nominal data source.

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

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

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.

fn write_prometheus_batches( &self, auth_: &BearerToken, data_source_rid: &NominalDataSourceOrDatasetRid, request: impl WriteBody<O>, ) -> Result<(), Error>

Synchronously writes batches of records to a Nominal data source.

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.

fn write_nominal_batches( &self, auth_: &BearerToken, data_source_rid: &NominalDataSourceOrDatasetRid, request: impl WriteBody<O>, ) -> 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.

fn write_nominal_columnar_batches( &self, auth_: &BearerToken, request: impl WriteBody<O>, ) -> Result<(), Error>

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

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

Synchronously writes logs to a Nominal data source.

impl<C> Service<C> for NominalChannelWriterServiceClient<C>

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

Creates a new service wrapping an HTTP client.