neiam /mutant-operator

An Experimental Operator

mutant-deployment: drop unused imports; reconcile's context is _ctx

36c0c87 · Gabe Morell · 2026-11-05 00:19

3 files +4 -6

Message

{commit_body(@commit)}

modified src/bin/main-deployment.rs

+4 −6

@@ -1,18 +1,16 @@

1	1	use futures::StreamExt;
2		−use k8s_openapi::api::{apps::v1::Deployment, core::v1::EnvVar};
	2	+use k8s_openapi::api::apps::v1::Deployment;
3	3	use kube::{
4		− api::{Api, DeleteParams, ListParams, ObjectMeta, PostParams},
	4	+ api::{Api, PostParams},
5	5	runtime::controller::{self, Action, Controller},
6	6	Client, CustomResource, ResourceExt,
7	7	};
8	8	use schemars::JsonSchema;
9	9	use serde::{Deserialize, Serialize};
10	10	use std::{collections::HashMap, fmt, sync::Arc};
11		−use kube::api::{Patch, PatchParams};
12	11	use kube::runtime::watcher;
13	12	use tokio::time::Duration;
14		−use tracing::{info, instrument};
15		−use std::error::Error;
	13	+use tracing::info;
16	14
17	15	// Define a custom error type
18	16	#[derive(Debug)]

@@ -65,7 +63,7 @@ pub struct Mutation {

65	63	}
66	64
67	65	// #[instrument(skip(_ctx))]
68		−async fn reconcile(mutant: Arc<MutantDeployment>, ctx: Arc<()>) -> Result<Action, MutantopsError> {
	66	+async fn reconcile(mutant: Arc<MutantDeployment>, _ctx: Arc<()>) -> Result<Action, MutantopsError> {
69	67	let client = Client::try_default().await?;
70	68	let deployments: Api<Deployment> = Api::namespaced(client.clone(), &mutant.namespace().unwrap());
71	69

Parents: 52a9112