[−][src]Struct k8_client::K8Client
K8 Cluster accessible thru API
Implementations
impl K8Client
[src]
pub fn default() -> Result<Self, ClientError>
[src]
pub fn new(config: K8Config) -> Result<Self, ClientError>
[src]
pub async fn retrieve_items_inner<S, N, '_>(
&'_ self,
namespace: N,
options: Option<ListOptions>
) -> Result<K8List<S>, ClientError> where
S: Spec,
N: Into<NameSpace> + Send + Sync,
[src]
&'_ self,
namespace: N,
options: Option<ListOptions>
) -> Result<K8List<S>, ClientError> where
S: Spec,
N: Into<NameSpace> + Send + Sync,
Trait Implementations
impl Debug for K8Client
[src]
impl MetadataClient for K8Client
[src]
type MetadataClientError = ClientError
fn retrieve_item<'life0, 'life1, 'async_trait, S, M>(
&'life0 self,
metadata: &'life1 M
) -> Pin<Box<dyn Future<Output = Result<K8Obj<S>, ClientError>> + Send + 'async_trait>> where
S: Spec,
M: K8Meta + Send + Sync,
S: 'async_trait,
M: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
[src]
&'life0 self,
metadata: &'life1 M
) -> Pin<Box<dyn Future<Output = Result<K8Obj<S>, ClientError>> + Send + 'async_trait>> where
S: Spec,
M: K8Meta + Send + Sync,
S: 'async_trait,
M: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
retrieval a single item
fn retrieve_items_with_option<'life0, 'async_trait, S, N>(
&'life0 self,
namespace: N,
option: Option<ListArg>
) -> Pin<Box<dyn Future<Output = Result<K8List<S>, ClientError>> + Send + 'async_trait>> where
S: Spec,
N: Into<NameSpace> + Send + Sync,
S: 'async_trait,
N: 'async_trait,
'life0: 'async_trait,
Self: 'async_trait,
[src]
&'life0 self,
namespace: N,
option: Option<ListArg>
) -> Pin<Box<dyn Future<Output = Result<K8List<S>, ClientError>> + Send + 'async_trait>> where
S: Spec,
N: Into<NameSpace> + Send + Sync,
S: 'async_trait,
N: 'async_trait,
'life0: 'async_trait,
Self: 'async_trait,
fn retrieve_items_in_chunks<'a, S, N>(
self: Arc<Self>,
namespace: N,
limit: u32,
option: Option<ListArg>
) -> BoxStream<'a, K8List<S>> where
S: Spec + 'static,
N: Into<NameSpace> + Send + Sync + 'static,
[src]
self: Arc<Self>,
namespace: N,
limit: u32,
option: Option<ListArg>
) -> BoxStream<'a, K8List<S>> where
S: Spec + 'static,
N: Into<NameSpace> + Send + Sync + 'static,
fn delete_item<'life0, 'life1, 'async_trait, S, M>(
&'life0 self,
metadata: &'life1 M
) -> Pin<Box<dyn Future<Output = Result<K8Status, ClientError>> + Send + 'async_trait>> where
S: Spec,
M: K8Meta + Send + Sync,
S: 'async_trait,
M: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
[src]
&'life0 self,
metadata: &'life1 M
) -> Pin<Box<dyn Future<Output = Result<K8Status, ClientError>> + Send + 'async_trait>> where
S: Spec,
M: K8Meta + Send + Sync,
S: 'async_trait,
M: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
fn create_item<'life0, 'async_trait, S>(
&'life0 self,
value: InputK8Obj<S>
) -> Pin<Box<dyn Future<Output = Result<K8Obj<S>, ClientError>> + Send + 'async_trait>> where
S: Spec,
S: 'async_trait,
'life0: 'async_trait,
Self: 'async_trait,
[src]
&'life0 self,
value: InputK8Obj<S>
) -> Pin<Box<dyn Future<Output = Result<K8Obj<S>, ClientError>> + Send + 'async_trait>> where
S: Spec,
S: 'async_trait,
'life0: 'async_trait,
Self: 'async_trait,
create new object
fn update_status<'life0, 'life1, 'async_trait, S>(
&'life0 self,
value: &'life1 UpdateK8ObjStatus<S>
) -> Pin<Box<dyn Future<Output = Result<K8Obj<S>, ClientError>> + Send + 'async_trait>> where
S: Spec,
S: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
[src]
&'life0 self,
value: &'life1 UpdateK8ObjStatus<S>
) -> Pin<Box<dyn Future<Output = Result<K8Obj<S>, ClientError>> + Send + 'async_trait>> where
S: Spec,
S: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
update status
fn patch_spec<'life0, 'life1, 'life2, 'async_trait, S, M>(
&'life0 self,
metadata: &'life1 M,
patch: &'life2 Value
) -> Pin<Box<dyn Future<Output = Result<K8Obj<S>, ClientError>> + Send + 'async_trait>> where
S: Spec,
M: K8Meta + Display + Send + Sync,
S: 'async_trait,
M: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
Self: 'async_trait,
[src]
&'life0 self,
metadata: &'life1 M,
patch: &'life2 Value
) -> Pin<Box<dyn Future<Output = Result<K8Obj<S>, ClientError>> + Send + 'async_trait>> where
S: Spec,
M: K8Meta + Display + Send + Sync,
S: 'async_trait,
M: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
Self: 'async_trait,
patch existing with spec
fn watch_stream_since<S, N>(
&self,
namespace: N,
resource_version: Option<String>
) -> BoxStream<'_, TokenStreamResult<S, Self::MetadataClientError>> where
S: Spec + 'static,
S::Status: 'static,
S::Header: 'static,
N: Into<NameSpace>,
[src]
&self,
namespace: N,
resource_version: Option<String>
) -> BoxStream<'_, TokenStreamResult<S, Self::MetadataClientError>> where
S: Spec + 'static,
S::Status: 'static,
S::Header: 'static,
N: Into<NameSpace>,
stream items since resource versions
#[must_use]fn retrieve_items<'life0, 'async_trait, S, N>(
&'life0 self,
namespace: N
) -> Pin<Box<dyn Future<Output = Result<K8List<S>, Self::MetadataClientError>> + 'async_trait + Send>> where
'life0: 'async_trait,
N: Into<NameSpace> + Send + Sync + 'async_trait,
S: Spec + 'async_trait,
Self: 'async_trait,
[src]
&'life0 self,
namespace: N
) -> Pin<Box<dyn Future<Output = Result<K8List<S>, Self::MetadataClientError>> + 'async_trait + Send>> where
'life0: 'async_trait,
N: Into<NameSpace> + Send + Sync + 'async_trait,
S: Spec + 'async_trait,
Self: 'async_trait,
#[must_use]fn apply<'life0, 'async_trait, S>(
&'life0 self,
value: K8SpecObj<S, InputObjectMeta>
) -> Pin<Box<dyn Future<Output = Result<ApplyResult<S>, Self::MetadataClientError>> + 'async_trait + Send>> where
'life0: 'async_trait,
S: Spec + 'async_trait,
Self: 'async_trait,
Self::MetadataClientError: From<Error>,
Self::MetadataClientError: From<DiffError>,
Self::MetadataClientError: Send,
[src]
&'life0 self,
value: K8SpecObj<S, InputObjectMeta>
) -> Pin<Box<dyn Future<Output = Result<ApplyResult<S>, Self::MetadataClientError>> + 'async_trait + Send>> where
'life0: 'async_trait,
S: Spec + 'async_trait,
Self: 'async_trait,
Self::MetadataClientError: From<Error>,
Self::MetadataClientError: From<DiffError>,
Self::MetadataClientError: Send,
fn watch_stream_now<S>(
&self,
ns: String
) -> Pin<Box<dyn Stream<Item = Result<Vec<Result<K8Watch<S>, Self::MetadataClientError>>, Self::MetadataClientError>> + Send>> where
S: Spec + 'static,
[src]
&self,
ns: String
) -> Pin<Box<dyn Stream<Item = Result<Vec<Result<K8Watch<S>, Self::MetadataClientError>>, Self::MetadataClientError>> + Send>> where
S: Spec + 'static,
#[must_use]fn exists<'life0, 'life1, 'async_trait, S, M>(
&'life0 self,
metadata: &'life1 M
) -> Pin<Box<dyn Future<Output = Result<bool, Self::MetadataClientError>> + 'async_trait + Send>> where
'life0: 'async_trait,
'life1: 'async_trait,
M: K8Meta + Display + Send + Sync + 'async_trait,
S: Spec + 'async_trait,
Self: 'async_trait,
[src]
&'life0 self,
metadata: &'life1 M
) -> Pin<Box<dyn Future<Output = Result<bool, Self::MetadataClientError>> + 'async_trait + Send>> where
'life0: 'async_trait,
'life1: 'async_trait,
M: K8Meta + Display + Send + Sync + 'async_trait,
S: Spec + 'async_trait,
Self: 'async_trait,
Auto Trait Implementations
impl !RefUnwindSafe for K8Client
impl Send for K8Client
impl Sync for K8Client
impl Unpin for K8Client
impl !UnwindSafe for K8Client
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T> Instrument for T
[src]
fn instrument(self, span: Span) -> Instrumented<Self>
[src]
fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,
fn vzip(self) -> V
impl<T> WithSubscriber for T
[src]
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
[src]
S: Into<Dispatch>,