Struct google_api_proto::google::cloud::video::livestream::v1::livestream_service_client::LivestreamServiceClient

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

Using Live Stream API, you can generate live streams in the various renditions and streaming formats. The streaming format include HTTP Live Streaming (HLS) and Dynamic Adaptive Streaming over HTTP (DASH). You can send a source stream in the various ways, including Real-Time Messaging Protocol (RTMP) and Secure Reliable Transport (SRT).

Implementations

impl<T> LivestreamServiceClient<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, ) -> LivestreamServiceClient<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_channel( &mut self, request: impl IntoRequest<CreateChannelRequest>, ) -> Result<Response<Operation>, Status>

Creates a channel with the provided unique ID in the specified region.

pub async fn list_channels( &mut self, request: impl IntoRequest<ListChannelsRequest>, ) -> Result<Response<ListChannelsResponse>, Status>

Returns a list of all channels in the specified region.

pub async fn get_channel( &mut self, request: impl IntoRequest<GetChannelRequest>, ) -> Result<Response<Channel>, Status>

Returns the specified channel.

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

Deletes the specified channel.

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

Updates the specified channel.

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

Starts the specified channel. Part of the video pipeline will be created only when the StartChannel request is received by the server.

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

Stops the specified channel. Part of the video pipeline will be released when the StopChannel request is received by the server.

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

Creates an input with the provided unique ID in the specified region.

pub async fn list_inputs( &mut self, request: impl IntoRequest<ListInputsRequest>, ) -> Result<Response<ListInputsResponse>, Status>

Returns a list of all inputs in the specified region.

pub async fn get_input( &mut self, request: impl IntoRequest<GetInputRequest>, ) -> Result<Response<Input>, Status>

Returns the specified input.

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

Deletes the specified input.

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

Updates the specified input.

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

Creates an event with the provided unique ID in the specified channel.

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

Returns a list of all events in the specified channel.

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

Returns the specified event.

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

Deletes the specified event.

pub async fn list_clips( &mut self, request: impl IntoRequest<ListClipsRequest>, ) -> Result<Response<ListClipsResponse>, Status>

Returns a list of all clips in the specified channel.

pub async fn get_clip( &mut self, request: impl IntoRequest<GetClipRequest>, ) -> Result<Response<Clip>, Status>

Returns the specified clip.

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

Creates a clip with the provided clip ID in the specified channel.

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

Deletes the specified clip job resource. This method only deletes the clip job and does not delete the VOD clip stored in the GCS.

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

Creates a Asset with the provided unique ID in the specified region.

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

Deletes the specified asset if it is not used.

pub async fn get_asset( &mut self, request: impl IntoRequest<GetAssetRequest>, ) -> Result<Response<Asset>, Status>

Returns the specified asset.

pub async fn list_assets( &mut self, request: impl IntoRequest<ListAssetsRequest>, ) -> Result<Response<ListAssetsResponse>, Status>

Returns a list of all assets in the specified region.

pub async fn get_pool( &mut self, request: impl IntoRequest<GetPoolRequest>, ) -> Result<Response<Pool>, Status>

Returns the specified pool.

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

Updates the specified pool.

Trait Implementations

impl<T: Clone> Clone for LivestreamServiceClient<T>

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

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for LivestreamServiceClient<T>

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

Formats the value using the given formatter.