Struct KubernetesApplierSender

pub struct KubernetesApplierSender<T: Transport> { /* private fields */ }

KubernetesApplierSender sends messages to a KubernetesApplier service The KubernetesApplier service has a two methods, one to apply an object (that can be a create or update) and to delete an object client for sending KubernetesApplier messages

Implementations

impl<T: Transport> KubernetesApplierSender<T>

pub fn via(transport: T) -> Self

Constructs a KubernetesApplierSender with the specified transport

pub fn set_timeout(&self, interval: Duration)

Trait Implementations

impl<T: Debug + Transport> Debug for KubernetesApplierSender<T>

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

Formats the value using the given formatter.

impl<T: Transport + Sync + Send> KubernetesApplier for KubernetesApplierSender<T>

fn apply<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, ctx: &'life1 Context, arg: &'life2 Vec<u8>, ) -> Pin<Box<dyn Future<Output = RpcResult<OperationResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Attempts to create or update the arbitrary object it is given

fn delete<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, ctx: &'life1 Context, arg: &'life2 DeleteRequest, ) -> Pin<Box<dyn Future<Output = RpcResult<OperationResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Attempts to delete an object with the given GVK (group, version, kind), name, and namespace. This should be idempotent, meaning that it should return successful if the object doesn’t exist

fn contract_id() -> &'static str

returns the capability contract id for this interface