Struct Context 

pub struct Context {
    pub client: Client,
    pub config: Arc<OperatorConfig>,
    pub registry: SharedRegistry,
    pub admin_clients: Arc<Mutex<HashMap<String, AdminClientHandle>>>,
    pub rebalancer_clients: Arc<Mutex<HashMap<String, RebalancerClientHandle>>>,
}

Shared per-reconciler context. Cheap to clone (all fields Arc / shared via interior mutability).

Fields

client: Client

config: Arc<OperatorConfig>

registry: SharedRegistry

admin_clients: Arc<Mutex<HashMap<String, AdminClientHandle>>>

Per-cluster admin-client cache. Keyed by Kafka resource name. Broken connections are replaced lazily on next use.

rebalancer_clients: Arc<Mutex<HashMap<String, RebalancerClientHandle>>>

Per-endpoint rebalancer-client cache. Keyed by the resolved Connect base URL. Dropped + re-created lazily on transport failure.

Implementations

impl Context

pub fn new( client: Client, config: OperatorConfig, registry: SharedRegistry, ) -> Self

pub async fn admin_client_for( &self, cluster: &str, bootstrap: &str, ) -> Result<AdminClientHandle, AdminError>

Look up or open an AdminClient for the named cluster.

bootstrap is the inter-broker listener’s bootstrap_servers string, e.g. demo-broker-headless.default.svc.cluster.local:9092.

pub async fn drop_admin_client(&self, cluster: &str)

Drop the cached admin client for cluster (used by reconcile when a Transport error indicates the connection died — next call will reopen).

pub async fn insert_admin_client_for_test( &self, cluster: &str, admin: AdminClientHandle, )

Test-only: pre-populate the admin-client cache with a caller-supplied handle. The AdminClientLike trait abstracts over the real client and per-test fakes, so reconcile tests can drive the trait methods without opening a TCP connection.

Not cfg-gated: the function exists in the public API but is harmless (and unused) in production — keeping it un-gated avoids a parallel test-only build profile.

pub async fn rebalancer_client_for( &self, endpoint: &str, ) -> RebalancerClientHandle

Look up or build a rebalancer client for endpoint (a Connect base URL like http://host:9300). Construction is infallible (no connection is opened until the first RPC), so this returns the handle directly.

pub async fn drop_rebalancer_client(&self, endpoint: &str)

Drop the cached rebalancer client for endpoint (used by reconcile after a transport error — the next call rebuilds it).

pub async fn insert_rebalancer_client_for_test( &self, endpoint: &str, client: RebalancerClientHandle, )

Test-only: pre-populate the rebalancer-client cache with a fake. Mirrors Self::insert_admin_client_for_test.

Trait Implementations

impl Clone for Context

fn clone(&self) -> Context

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.