Struct googapis::google::cloud::video::livestream::v1::livestream_service_client::LivestreamServiceClient [−][src]
pub struct LivestreamServiceClient<T> { /* fields omitted */ }
Expand description
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::ResponseBody: Body + Send + 'static,
T::Error: Into<StdError>,
<T::ResponseBody as Body>::Error: Into<StdError> + Send,
impl<T> LivestreamServiceClient<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
) -> LivestreamServiceClient<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,
Compress requests with gzip
.
This requires the server to support it otherwise it might respond with an error.
Enable decompressing responses with gzip
.
pub async fn create_channel(
&mut self,
request: impl IntoRequest<CreateChannelRequest>
) -> Result<Response<Operation>, Status>
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>
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>
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>
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>
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>
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>
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>
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>
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>
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>
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>
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>
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>
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>
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>
pub async fn delete_event(
&mut self,
request: impl IntoRequest<DeleteEventRequest>
) -> Result<Response<()>, Status>
Deletes the specified event.
Trait Implementations
Auto Trait Implementations
impl<T> RefUnwindSafe for LivestreamServiceClient<T> where
T: RefUnwindSafe,
impl<T> Send for LivestreamServiceClient<T> where
T: Send,
impl<T> Sync for LivestreamServiceClient<T> where
T: Sync,
impl<T> Unpin for LivestreamServiceClient<T> where
T: Unpin,
impl<T> UnwindSafe for LivestreamServiceClient<T> where
T: UnwindSafe,
Blanket Implementations
Mutably borrows from an owned value. Read more
Wrap the input message T
in a tonic::Request
pub fn vzip(self) -> V
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more