Struct Controller 

pub struct Controller<K>
where
    K: Resource<DynamicType = ()> + Clone + Debug + 'static,
{ /* private fields */ }

Available on crate feature k8s only.

One controller: a kind, what it owns, how it reconciles. See the module docs.

Implementations

impl<K> Controller<K>

where K: Resource<DynamicType = ()> + Clone + DeserializeOwned + Serialize + Debug + Send + Sync + 'static, <K as Resource>::Scope: Scope,

pub fn new(api: Api<K>) -> Controller<K>

Watch api’s objects (Api::all or Api::namespaced).

pub fn watching(self, config: Config) -> Controller<K>

Only the objects config selects (labels, fields).

pub fn owns<C>(self, api: Api<C>) -> Controller<K>

where C: Resource<DynamicType = ()> + Clone + DeserializeOwned + Debug + Send + Sync + 'static,

Also reconcile an object when a C it owns (an owner reference) changes — the Deployment of a custom resource, say.

pub fn reconcile<F, Fut>(self, f: F) -> Controller<K>

where F: Fn(Arc<K>, Arc<Context>) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<Action, Error>> + Send + 'static,

The reconcile function: make the world match the object, answer when to look again.

pub fn finalizer<F, Fut>(self, name: &str, cleanup: F) -> Controller<K>

where F: Fn(Arc<K>, Arc<Context>) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<(), Error>> + Send + 'static,

Add the finalizer name to every object and run cleanup when one is deleted; the finalizer is removed (letting the deletion finish) once cleanup succeeds.

pub fn on_error(self, first_delay: Duration) -> Controller<K>

The first delay before retrying a failed reconcile (doubling per failure of the same object, up to 5 min). Default 5 s.

pub fn rule(self, rule: Rule) -> Controller<K>

Extra RBAC rules the reconcile needs (reading Secrets, say).

Trait Implementations

impl<K> Runnable for Controller<K>

where K: Resource<DynamicType = ()> + Clone + DeserializeOwned + Serialize + Debug + Send + Sync + 'static, <K as Resource>::Scope: Scope,

fn kind(&self) -> String

fn rules(&self) -> Vec<Rule>

fn start( self: Box<Controller<K>>, client: Client, ctx: Arc<Context>, ) -> Pin<Box<dyn Future<Output = ()> + Send>>