Struct Controller

pub struct Controller<Ctx>
where
    Ctx: Send + Sync + 'static + Context,
    Ctx::Error: Send + Sync + 'static,
    for<'de> Ctx::Resource: Send + Sync + 'static + Clone + Debug + Serialize + Deserialize<'de>,
    <Ctx::Resource as Resource>::DynamicType: Eq + Clone + Hash + Default + Debug + Unpin,
{ /* private fields */ }

The Controller watches a set of resources, calling methods on the provided Context when events occur.

Implementations

impl<Ctx> Controller<Ctx>

where Ctx: Send + Sync + 'static + Context, Ctx::Error: Send + Sync + 'static, for<'de> Ctx::Resource: Send + Sync + 'static + Clone + Debug + Serialize + Deserialize<'de>, <Ctx::Resource as Resource>::DynamicType: Eq + Clone + Hash + Default + Debug + Unpin,

pub fn namespaced( client: Client, context: Ctx, namespace: &str, wc: Config, ) -> Self

where Ctx::Resource: Resource<Scope = NamespaceResourceScope>,

Creates a new controller for a namespaced resource using the given client. The context given determines the type of resource to watch (via the Context::Resource type provided as part of the trait implementation). The resources to be watched will be limited to resources in the given namespace. A watcher::Config can be given to limit the resources watched (for instance, watcher::Config::default().labels("app=myapp")).

pub fn namespaced_all(client: Client, context: Ctx, wc: Config) -> Self

where Ctx::Resource: Resource<Scope = NamespaceResourceScope>,

Creates a new controller for a namespaced resource using the given client. The context given determines the type of resource to watch (via the Context::Resource type provided as part of the trait implementation). The resources to be watched will not be limited by namespace. A watcher::Config can be given to limit the resources watched (for instance, watcher::Config::default().labels("app=myapp")).

pub fn cluster(client: Client, context: Ctx, wc: Config) -> Self

where Ctx::Resource: Resource<Scope = ClusterResourceScope>,

Creates a new controller for a cluster-scoped resource using the given client. The context given determines the type of resource to watch (via the Context::Resource type provided as part of the trait implementation). A watcher::Config can be given to limit the resources watched (for instance, watcher::Config::default().labels("app=myapp")).

pub async fn run(self)

Run the controller. This method will not return. The Context given to the constructor will have its apply method called when a resource is created or updated, and its cleanup method called when a resource is about to be deleted.

pub fn with_concurrency(self, concurrency: u16) -> Self