Struct google_api_proto::google::cloud::visionai::v1alpha1::streams_service_client::StreamsServiceClient

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

Service describing handlers for resources. Vision API and Vision AI API are two independent APIs developed by the same team. Vision API is for people to annotate their image while Vision AI is an e2e solution for customer to build their own computer vision application.

Implementations

impl<T> StreamsServiceClient<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, ) -> StreamsServiceClient<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 list_clusters( &mut self, request: impl IntoRequest<ListClustersRequest>, ) -> Result<Response<ListClustersResponse>, Status>

Lists Clusters in a given project and location.

pub async fn get_cluster( &mut self, request: impl IntoRequest<GetClusterRequest>, ) -> Result<Response<Cluster>, Status>

Gets details of a single Cluster.

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

Creates a new Cluster in a given project and location.

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

Updates the parameters of a single Cluster.

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

Deletes a single Cluster.

pub async fn list_streams( &mut self, request: impl IntoRequest<ListStreamsRequest>, ) -> Result<Response<ListStreamsResponse>, Status>

Lists Streams in a given project and location.

pub async fn get_stream( &mut self, request: impl IntoRequest<GetStreamRequest>, ) -> Result<Response<Stream>, Status>

Gets details of a single Stream.

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

Creates a new Stream in a given project and location.

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

Updates the parameters of a single Stream.

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

Deletes a single Stream.

pub async fn generate_stream_hls_token( &mut self, request: impl IntoRequest<GenerateStreamHlsTokenRequest>, ) -> Result<Response<GenerateStreamHlsTokenResponse>, Status>

Generate the JWT auth token required to get the stream HLS contents.

pub async fn list_events( &mut self, request: impl IntoRequest<ListEventsRequest>, ) -> Result<Response<ListEventsResponse>, Status>

Lists Events in a given project and location.

pub async fn get_event( &mut self, request: impl IntoRequest<GetEventRequest>, ) -> Result<Response<Event>, Status>

Gets details of a single Event.

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

Creates a new Event in a given project and location.

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

Updates the parameters of a single Event.

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

Deletes a single Event.

pub async fn list_series( &mut self, request: impl IntoRequest<ListSeriesRequest>, ) -> Result<Response<ListSeriesResponse>, Status>

Lists Series in a given project and location.

pub async fn get_series( &mut self, request: impl IntoRequest<GetSeriesRequest>, ) -> Result<Response<Series>, Status>

Gets details of a single Series.

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

Creates a new Series in a given project and location.

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

Updates the parameters of a single Event.

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

Deletes a single Series.

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

Materialize a channel.

Trait Implementations

impl<T: Clone> Clone for StreamsServiceClient<T>

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

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for StreamsServiceClient<T>

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

Formats the value using the given formatter.