Struct ConfigPusher 

pub struct ConfigPusher { /* private fields */ }

Configuration pusher for distributing config updates to agents.

This allows the proxy to push configuration changes (rules, lists, etc.) to connected agents and track acknowledgments.

Implementations

impl ConfigPusher

pub fn new() -> Self

Create a new config pusher with default configuration.

pub fn with_config(config: ConfigPusherConfig) -> Self

Create a new config pusher with custom configuration.

pub fn register_agent( &self, agent_id: impl Into<String>, name: impl Into<String>, supports_push: bool, )

Register a connected agent.

pub fn unregister_agent(&self, agent_id: &str)

Unregister a disconnected agent.

pub fn touch_agent(&self, agent_id: &str)

Update agent’s last seen time.

pub fn connected_agents(&self) -> Vec<AgentConnection>

Get all connected agents.

pub fn pushable_agents(&self) -> Vec<AgentConnection>

Get agents that support config push.

pub fn push_to_agent( &self, agent_id: &str, update_type: ConfigUpdateType, ) -> Option<String>

Push a configuration update to a specific agent.

pub fn push_to_all(&self, update_type: ConfigUpdateType) -> Vec<String>

Push a configuration update to all pushable agents.

pub fn acknowledge(&self, push_id: &str, accepted: bool, error: Option<String>)

Acknowledge a config push.

pub fn get_retryable(&self) -> Vec<(String, ConfigUpdateRequest)>

Get pushes that need to be retried.

pub fn expire_old(&self)

Expire old pending pushes.

pub fn get_results(&self) -> Vec<PushResult>

Get push results.

pub fn pending_count(&self) -> usize

Get pending push count.

Trait Implementations

impl Debug for ConfigPusher

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

Formats the value using the given formatter.

impl Default for ConfigPusher

fn default() -> Self

Returns the “default value” for a type.