Struct google_api_proto::google::cloud::gkeconnect::gateway::v1beta1::gateway_service_client::GatewayServiceClient
source · pub struct GatewayServiceClient<T> { /* private fields */ }
Expand description
Gateway service is a public API which works as a Kubernetes resource model proxy between end users and registered Kubernetes clusters. Each RPC in this service matches with an HTTP verb. End user will initiate kubectl commands against the Gateway service, and Gateway service will forward user requests to clusters.
Implementations§
source§impl<T> GatewayServiceClient<T>where
T: GrpcService<BoxBody>,
T::Error: Into<StdError>,
T::ResponseBody: Body<Data = Bytes> + Send + 'static,
<T::ResponseBody as Body>::Error: Into<StdError> + Send,
impl<T> GatewayServiceClient<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
) -> GatewayServiceClient<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,
sourcepub fn send_compressed(self, encoding: CompressionEncoding) -> Self
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.
sourcepub fn accept_compressed(self, encoding: CompressionEncoding) -> Self
pub fn accept_compressed(self, encoding: CompressionEncoding) -> Self
Enable decompressing responses.
sourcepub fn max_decoding_message_size(self, limit: usize) -> Self
pub fn max_decoding_message_size(self, limit: usize) -> Self
Limits the maximum size of a decoded message.
Default: 4MB
sourcepub fn max_encoding_message_size(self, limit: usize) -> Self
pub fn max_encoding_message_size(self, limit: usize) -> Self
Limits the maximum size of an encoded message.
Default: usize::MAX
sourcepub async fn get_resource(
&mut self,
request: impl IntoRequest<HttpBody>
) -> Result<Response<HttpBody>, Status>
pub async fn get_resource( &mut self, request: impl IntoRequest<HttpBody> ) -> Result<Response<HttpBody>, Status>
GetResource performs an HTTP GET request on the Kubernetes API Server.
sourcepub async fn post_resource(
&mut self,
request: impl IntoRequest<HttpBody>
) -> Result<Response<HttpBody>, Status>
pub async fn post_resource( &mut self, request: impl IntoRequest<HttpBody> ) -> Result<Response<HttpBody>, Status>
PostResource performs an HTTP POST on the Kubernetes API Server.
sourcepub async fn delete_resource(
&mut self,
request: impl IntoRequest<HttpBody>
) -> Result<Response<HttpBody>, Status>
pub async fn delete_resource( &mut self, request: impl IntoRequest<HttpBody> ) -> Result<Response<HttpBody>, Status>
DeleteResource performs an HTTP DELETE on the Kubernetes API Server.
sourcepub async fn put_resource(
&mut self,
request: impl IntoRequest<HttpBody>
) -> Result<Response<HttpBody>, Status>
pub async fn put_resource( &mut self, request: impl IntoRequest<HttpBody> ) -> Result<Response<HttpBody>, Status>
PutResource performs an HTTP PUT on the Kubernetes API Server.
sourcepub async fn patch_resource(
&mut self,
request: impl IntoRequest<HttpBody>
) -> Result<Response<HttpBody>, Status>
pub async fn patch_resource( &mut self, request: impl IntoRequest<HttpBody> ) -> Result<Response<HttpBody>, Status>
PatchResource performs an HTTP PATCH on the Kubernetes API Server.
Trait Implementations§
source§impl<T: Clone> Clone for GatewayServiceClient<T>
impl<T: Clone> Clone for GatewayServiceClient<T>
source§fn clone(&self) -> GatewayServiceClient<T>
fn clone(&self) -> GatewayServiceClient<T>
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moreAuto Trait Implementations§
impl<T> !Freeze for GatewayServiceClient<T>
impl<T> RefUnwindSafe for GatewayServiceClient<T>where
T: RefUnwindSafe,
impl<T> Send for GatewayServiceClient<T>where
T: Send,
impl<T> Sync for GatewayServiceClient<T>where
T: Sync,
impl<T> Unpin for GatewayServiceClient<T>where
T: Unpin,
impl<T> UnwindSafe for GatewayServiceClient<T>where
T: UnwindSafe,
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T
in a tonic::Request