Struct google_api_proto::google::cloud::dataplex::v1::data_scan_service_client::DataScanServiceClient

pub struct DataScanServiceClient<T> { /* private fields */ }

DataScanService manages DataScan resources which can be configured to run various types of data scanning workload and generate enriched metadata (e.g. Data Profile, Data Quality) for the data source.

Implementations

impl<T> DataScanServiceClient<T>

where T: GrpcService<BoxBody>, T::Error: Into<StdError>, T::ResponseBody: Body<Data = Bytes> + Send + 'static, <T::ResponseBody as Body>::Error: Into<StdError> + Send,

pub fn new(inner: T) -> Self

pub fn with_origin(inner: T, origin: Uri) -> Self

pub fn with_interceptor<F>( inner: T, interceptor: F ) -> DataScanServiceClient<InterceptedService<T, F>>

where F: Interceptor, T::ResponseBody: Default, T: Service<Request<BoxBody>, Response = Response<<T as GrpcService<BoxBody>>::ResponseBody>>, <T as Service<Request<BoxBody>>>::Error: Into<StdError> + Send + Sync,

pub fn send_compressed(self, encoding: CompressionEncoding) -> Self

Compress requests with the given encoding.

This requires the server to support it otherwise it might respond with an error.

pub fn accept_compressed(self, encoding: CompressionEncoding) -> Self

Enable decompressing responses.

pub fn max_decoding_message_size(self, limit: usize) -> Self

Limits the maximum size of a decoded message.

Default: 4MB

pub fn max_encoding_message_size(self, limit: usize) -> Self

Limits the maximum size of an encoded message.

Default: usize::MAX

pub async fn create_data_scan( &mut self, request: impl IntoRequest<CreateDataScanRequest> ) -> Result<Response<Operation>, Status>

Creates a DataScan resource.

pub async fn update_data_scan( &mut self, request: impl IntoRequest<UpdateDataScanRequest> ) -> Result<Response<Operation>, Status>

Updates a DataScan resource.

pub async fn delete_data_scan( &mut self, request: impl IntoRequest<DeleteDataScanRequest> ) -> Result<Response<Operation>, Status>

Deletes a DataScan resource.

pub async fn get_data_scan( &mut self, request: impl IntoRequest<GetDataScanRequest> ) -> Result<Response<DataScan>, Status>

Gets a DataScan resource.

pub async fn list_data_scans( &mut self, request: impl IntoRequest<ListDataScansRequest> ) -> Result<Response<ListDataScansResponse>, Status>

Lists DataScans.

pub async fn run_data_scan( &mut self, request: impl IntoRequest<RunDataScanRequest> ) -> Result<Response<RunDataScanResponse>, Status>

Runs an on-demand execution of a DataScan

pub async fn get_data_scan_job( &mut self, request: impl IntoRequest<GetDataScanJobRequest> ) -> Result<Response<DataScanJob>, Status>

Gets a DataScanJob resource.

pub async fn list_data_scan_jobs( &mut self, request: impl IntoRequest<ListDataScanJobsRequest> ) -> Result<Response<ListDataScanJobsResponse>, Status>

Lists DataScanJobs under the given DataScan.

pub async fn generate_data_quality_rules( &mut self, request: impl IntoRequest<GenerateDataQualityRulesRequest> ) -> Result<Response<GenerateDataQualityRulesResponse>, Status>

Generates recommended DataQualityRule from a data profiling DataScan.

Trait Implementations

impl<T: Clone> Clone for DataScanServiceClient<T>

fn clone(&self) -> DataScanServiceClient<T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for DataScanServiceClient<T>

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

Formats the value using the given formatter.