Struct googapis::google::cloud::retail::v2::product_service_client::ProductServiceClient[−][src]

pub struct ProductServiceClient<T> { /* fields omitted */ }

Expand description

Service for ingesting [Product][google.cloud.retail.v2.Product] information of the customer’s website.

Implementations

[src]

impl<T> ProductServiceClient<T> where
 T: GrpcService<BoxBody>,
 T::ResponseBody: Body + Send + 'static,
 T::Error: Into<StdError>,
 <T::ResponseBody as Body>::Error: Into<StdError> + Send,

[src]

pub fn new(inner: T) -> Self

[src]

pub fn with_interceptor<F>(
 inner: T,
 interceptor: F
) -> ProductServiceClient<InterceptedService<T, F>> where
 F: Interceptor,
 T: Service<Request<BoxBody>, Response = Response<<T as GrpcService<BoxBody>>::ResponseBody>>,
 <T as Service<Request<BoxBody>>>::Error: Into<StdError> + Send + Sync,

[src]

pub fn send_gzip(self) -> Self

Compress requests with gzip.

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

[src]

pub fn accept_gzip(self) -> Self

Enable decompressing responses with gzip.

[src]

pub async fn create_product(
&mut self,
request: impl IntoRequest<CreateProductRequest>
) -> Result<Response<Product>, Status>

Creates a [Product][google.cloud.retail.v2.Product].

[src]

pub async fn get_product(
&mut self,
request: impl IntoRequest<GetProductRequest>
) -> Result<Response<Product>, Status>

Gets a [Product][google.cloud.retail.v2.Product].

[src]

pub async fn list_products(
&mut self,
request: impl IntoRequest<ListProductsRequest>
) -> Result<Response<ListProductsResponse>, Status>

Gets a list of [Product][google.cloud.retail.v2.Product]s.

[src]

pub async fn update_product(
&mut self,
request: impl IntoRequest<UpdateProductRequest>
) -> Result<Response<Product>, Status>

Updates a [Product][google.cloud.retail.v2.Product].

[src]

pub async fn delete_product(
&mut self,
request: impl IntoRequest<DeleteProductRequest>
) -> Result<Response<()>, Status>

Deletes a [Product][google.cloud.retail.v2.Product].

[src]

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

Bulk import of multiple [Product][google.cloud.retail.v2.Product]s.

Request processing may be synchronous. No partial updating is supported. Non-existing items are created.

Note that it is possible for a subset of the [Product][google.cloud.retail.v2.Product]s to be successfully updated.

[src]

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

Updates inventory information for a [Product][google.cloud.retail.v2.Product] while respecting the last update timestamps of each inventory field.

This process is asynchronous and does not require the [Product][google.cloud.retail.v2.Product] to exist before updating fulfillment information. If the request is valid, the update will be enqueued and processed downstream. As a consequence, when a response is returned, updates are not immediately manifested in the [Product][google.cloud.retail.v2.Product] queried by [GetProduct][google.cloud.retail.v2.ProductService.GetProduct] or [ListProducts][google.cloud.retail.v2.ProductService.ListProducts].

When inventory is updated with [CreateProduct][google.cloud.retail.v2.ProductService.CreateProduct] and [UpdateProduct][google.cloud.retail.v2.ProductService.UpdateProduct], the specified inventory field value(s) will overwrite any existing value(s) while ignoring the last update time for this field. Furthermore, the last update time for the specified inventory fields will be overwritten to the time of the [CreateProduct][google.cloud.retail.v2.ProductService.CreateProduct] or [UpdateProduct][google.cloud.retail.v2.ProductService.UpdateProduct] request.

If no inventory fields are set in [CreateProductRequest.product][google.cloud.retail.v2.CreateProductRequest.product], then any pre-existing inventory information for this product will be used.

If no inventory fields are set in [UpdateProductRequest.set_mask][], then any existing inventory information will be preserved.

Pre-existing inventory information can only be updated with [SetInventory][google.cloud.retail.v2.ProductService.SetInventory], [AddFulfillmentPlaces][google.cloud.retail.v2.ProductService.AddFulfillmentPlaces], and [RemoveFulfillmentPlaces][google.cloud.retail.v2.ProductService.RemoveFulfillmentPlaces].

This feature is only available for users who have Retail Search enabled. Please submit a form here to contact cloud sales if you are interested in using Retail Search.

[src]

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

Incrementally adds place IDs to [Product.fulfillment_info.place_ids][google.cloud.retail.v2.FulfillmentInfo.place_ids].

This process is asynchronous and does not require the [Product][google.cloud.retail.v2.Product] to exist before updating fulfillment information. If the request is valid, the update will be enqueued and processed downstream. As a consequence, when a response is returned, the added place IDs are not immediately manifested in the [Product][google.cloud.retail.v2.Product] queried by [GetProduct][google.cloud.retail.v2.ProductService.GetProduct] or [ListProducts][google.cloud.retail.v2.ProductService.ListProducts].

This feature is only available for users who have Retail Search enabled. Please submit a form here to contact cloud sales if you are interested in using Retail Search.

[src]

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

Incrementally removes place IDs from a [Product.fulfillment_info.place_ids][google.cloud.retail.v2.FulfillmentInfo.place_ids].

This process is asynchronous and does not require the [Product][google.cloud.retail.v2.Product] to exist before updating fulfillment information. If the request is valid, the update will be enqueued and processed downstream. As a consequence, when a response is returned, the removed place IDs are not immediately manifested in the [Product][google.cloud.retail.v2.Product] queried by [GetProduct][google.cloud.retail.v2.ProductService.GetProduct] or [ListProducts][google.cloud.retail.v2.ProductService.ListProducts].

This feature is only available for users who have Retail Search enabled. Please submit a form here to contact cloud sales if you are interested in using Retail Search.

Trait Implementations

[src]

impl<T: Clone> Clone for ProductServiceClient<T>

[src]

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

Returns a copy of the value. Read more

1.0.0[src]

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

Performs copy-assignment from source. Read more

[src]

impl<T: Debug> Debug for ProductServiceClient<T>

[src]

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

Formats the value using the given formatter. Read more

Auto Trait Implementations

impl<T> RefUnwindSafe for ProductServiceClient<T> where
T: RefUnwindSafe,

impl<T> Send for ProductServiceClient<T> where
T: Send,

impl<T> Sync for ProductServiceClient<T> where
T: Sync,

impl<T> Unpin for ProductServiceClient<T> where
T: Unpin,

impl<T> UnwindSafe for ProductServiceClient<T> where
T: UnwindSafe,

Blanket Implementations

[src]

impl<T> Any for T where
T: 'static + ?Sized,

[src]

pub fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

[src]

impl<T> Borrow<T> for T where
T: ?Sized,

[src]

pub fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

[src]

impl<T> BorrowMut<T> for T where
T: ?Sized,

[src]

pub fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

[src]

impl<T> From<T> for T

[src]

pub fn from(t: T) -> T

Performs the conversion.

[src]

impl<T> Instrument for T

[src]

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

[src]

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

[src]

impl<T, U> Into for T where
U: From<T>,

[src]

pub fn into(self) -> U

Performs the conversion.

[src]

impl<T> IntoRequest<T> for T

[src]

pub fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request

[src]

impl<T> ToOwned for T where
T: Clone,

type Owned = T

The resulting type after obtaining ownership.

[src]

pub fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more

[src]

pub fn clone_into(&self, target: &mut T)

🔬 This is a nightly-only experimental API. (toowned_clone_into)

recently added

Uses borrowed data to replace owned data, usually by cloning. Read more

[src]

impl<T, U> TryFrom for T where
U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

[src]

pub fn try_from(value: U) -> Result<T, <T as TryFrom>::Error>

Performs the conversion.

[src]

impl<T, U> TryInto for T where
U: TryFrom<T>,

type Error = >::Error

The type returned in the event of a conversion error.

[src]

pub fn try_into(self) -> Result<U, >::Error>

Performs the conversion.

impl<V, T> VZip<V> for T where
V: MultiLane<T>,

pub fn vzip(self) -> V

[src]

impl<T> WithSubscriber for T

[src]

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

[src]

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more

Struct googapis::google::cloud::retail::v2::product_service_client::ProductServiceClient[−][src]

Implementations

impl<T> ProductServiceClient<T> where T: GrpcService<BoxBody>, T::ResponseBody: Body + Send + 'static, T::Error: Into<StdError>, <T::ResponseBody as Body>::Error: Into<StdError> + Send,

pub fn new(inner: T) -> Self

pub fn with_interceptor<F>( inner: T, interceptor: F) -> ProductServiceClient<InterceptedService<T, F>> where F: Interceptor, T: Service<Request<BoxBody>, Response = Response<<T as GrpcService<BoxBody>>::ResponseBody>>, <T as Service<Request<BoxBody>>>::Error: Into<StdError> + Send + Sync,

pub fn send_gzip(self) -> Self

pub fn accept_gzip(self) -> Self

pub async fn create_product( &mut self, request: impl IntoRequest<CreateProductRequest>) -> Result<Response<Product>, Status>

pub async fn get_product( &mut self, request: impl IntoRequest<GetProductRequest>) -> Result<Response<Product>, Status>

pub async fn list_products( &mut self, request: impl IntoRequest<ListProductsRequest>) -> Result<Response<ListProductsResponse>, Status>

pub async fn update_product( &mut self, request: impl IntoRequest<UpdateProductRequest>) -> Result<Response<Product>, Status>

pub async fn delete_product( &mut self, request: impl IntoRequest<DeleteProductRequest>) -> Result<Response<()>, Status>

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

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

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

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

Trait Implementations

impl<T: Clone> Clone for ProductServiceClient<T>

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

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

impl<T: Debug> Debug for ProductServiceClient<T>

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

Auto Trait Implementations

impl<T> RefUnwindSafe for ProductServiceClient<T> where T: RefUnwindSafe,

impl<T> Send for ProductServiceClient<T> where T: Send,

impl<T> Sync for ProductServiceClient<T> where T: Sync,

impl<T> Unpin for ProductServiceClient<T> where T: Unpin,

impl<T> UnwindSafe for ProductServiceClient<T> where T: UnwindSafe,

Blanket Implementations

impl<T> Any for T where T: 'static + ?Sized,

pub fn type_id(&self) -> TypeId

impl<T> Borrow<T> for T where T: ?Sized,

pub fn borrow(&self) -> &T

impl<T> BorrowMut<T> for T where T: ?Sized,

pub fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

pub fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for T where U: From<T>,

pub fn into(self) -> U

impl<T> IntoRequest<T> for T

pub fn into_request(self) -> Request<T>

impl<T> ToOwned for T where T: Clone,

type Owned = T

pub fn to_owned(&self) -> T

pub fn clone_into(&self, target: &mut T)

impl<T, U> TryFrom<U> for T where U: Into<T>,

type Error = Infallible

pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for T where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<V, T> VZip<V> for T where V: MultiLane<T>,

pub fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

impl<T> ProductServiceClient<T> where
T: GrpcService<BoxBody>,
T::ResponseBody: Body + Send + 'static,
T::Error: Into<StdError>,
<T::ResponseBody as Body>::Error: Into<StdError> + Send,

pub fn with_interceptor<F>(
inner: T,
interceptor: F
) -> ProductServiceClient<InterceptedService<T, F>> where
F: Interceptor,
T: Service<Request<BoxBody>, Response = Response<<T as GrpcService<BoxBody>>::ResponseBody>>,
<T as Service<Request<BoxBody>>>::Error: Into<StdError> + Send + Sync,

pub async fn create_product(
&mut self,
request: impl IntoRequest<CreateProductRequest>
) -> Result<Response<Product>, Status>

pub async fn get_product(
&mut self,
request: impl IntoRequest<GetProductRequest>
) -> Result<Response<Product>, Status>

pub async fn list_products(
&mut self,
request: impl IntoRequest<ListProductsRequest>
) -> Result<Response<ListProductsResponse>, Status>

pub async fn update_product(
&mut self,
request: impl IntoRequest<UpdateProductRequest>
) -> Result<Response<Product>, Status>

pub async fn delete_product(
&mut self,
request: impl IntoRequest<DeleteProductRequest>
) -> Result<Response<()>, Status>

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

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

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

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

impl<T> RefUnwindSafe for ProductServiceClient<T> where
T: RefUnwindSafe,

impl<T> Send for ProductServiceClient<T> where
T: Send,

impl<T> Sync for ProductServiceClient<T> where
T: Sync,

impl<T> Unpin for ProductServiceClient<T> where
T: Unpin,

impl<T> UnwindSafe for ProductServiceClient<T> where
T: UnwindSafe,

impl<T> Any for T where
T: 'static + ?Sized,

impl<T> Borrow<T> for T where
T: ?Sized,

impl<T> BorrowMut<T> for T where
T: ?Sized,

impl<T, U> Into<U> for T where
U: From<T>,

impl<T> ToOwned for T where
T: Clone,

impl<T, U> TryFrom<U> for T where
U: Into<T>,

impl<T, U> TryInto<U> for T where
U: TryFrom<T>,

impl<V, T> VZip<V> for T where
V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,