Trait AsyncContainerizedExtractorService 

pub trait AsyncContainerizedExtractorService<I>
where
    I: Stream<Item = Result<Bytes, Error>>,
{
    // Required methods
    fn register_containerized_extractor(
        &self,
        auth_: &BearerToken,
        request: &RegisterContainerizedExtractorRequest,
    ) -> impl Future<Output = Result<RegisterContainerizedExtractorResponse, Error>> + Send;
    fn get_containerized_extractor(
        &self,
        auth_: &BearerToken,
        extractor_rid: &ResourceIdentifier,
    ) -> impl Future<Output = Result<ContainerizedExtractor, Error>> + Send;
    fn search_containerized_extractors(
        &self,
        auth_: &BearerToken,
        request: &SearchContainerizedExtractorsRequest,
    ) -> impl Future<Output = Result<Vec<ContainerizedExtractor>, Error>> + Send;
    fn update_containerized_extractor(
        &self,
        auth_: &BearerToken,
        extractor_rid: &ResourceIdentifier,
        request: &UpdateContainerizedExtractorRequest,
    ) -> impl Future<Output = Result<ContainerizedExtractor, Error>> + Send;
    fn archive_containerized_extractor(
        &self,
        auth_: &BearerToken,
        extractor_rid: &ResourceIdentifier,
    ) -> impl Future<Output = Result<(), Error>> + Send;
    fn unarchive_containerized_extractor(
        &self,
        auth_: &BearerToken,
        extractor_rid: &ResourceIdentifier,
    ) -> impl Future<Output = Result<(), Error>> + Send;
}

The Containerized Extractor service provides functionality for creating, updating, and archiving containerized extractors.

Required Methods

fn register_containerized_extractor( &self, auth_: &BearerToken, request: &RegisterContainerizedExtractorRequest, ) -> impl Future<Output = Result<RegisterContainerizedExtractorResponse, Error>> + Send

Registers a containerized extractor for a given set of containerized files.

fn get_containerized_extractor( &self, auth_: &BearerToken, extractor_rid: &ResourceIdentifier, ) -> impl Future<Output = Result<ContainerizedExtractor, Error>> + Send

Get a containerized extractor by its RID.

fn search_containerized_extractors( &self, auth_: &BearerToken, request: &SearchContainerizedExtractorsRequest, ) -> impl Future<Output = Result<Vec<ContainerizedExtractor>, Error>> + Send

Search for containerized extractors based on query parameters.

fn update_containerized_extractor( &self, auth_: &BearerToken, extractor_rid: &ResourceIdentifier, request: &UpdateContainerizedExtractorRequest, ) -> impl Future<Output = Result<ContainerizedExtractor, Error>> + Send

Update a containerized extractor. Only the fields that are set in the request will be updated.

fn archive_containerized_extractor( &self, auth_: &BearerToken, extractor_rid: &ResourceIdentifier, ) -> impl Future<Output = Result<(), Error>> + Send

Archive a containerized extractor.

fn unarchive_containerized_extractor( &self, auth_: &BearerToken, extractor_rid: &ResourceIdentifier, ) -> impl Future<Output = Result<(), Error>> + Send

Unarchive a containerized extractor.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl<I, __C> AsyncContainerizedExtractorService<I> for AsyncContainerizedExtractorServiceClient<__C>

where I: Stream<Item = Result<Bytes, Error>>, __C: AsyncClient<ResponseBody = I> + Sync + Send, <__C as AsyncClient>::ResponseBody: 'static + Send,