Struct AgentLifecycle 

pub struct AgentLifecycle {
    pub agent_id: AgentId,
    pub agent_name: Option<AgentName>,
    pub version: AgentVersion,
    pub version_number: VersionNumber,
    pub current_state: AgentLifecycleState,
    pub previous_state: Option<AgentLifecycleState>,
    pub transition_timeout: TransitionTimeout,
    pub drain_timeout: DrainTimeout,
    pub pending_requests: PendingRequestCount,
    pub failure_reason: Option<FailureReason>,
}

Agent lifecycle state with metadata

Fields

agent_id: AgentId

agent_name: Option<AgentName>

version: AgentVersion

version_number: VersionNumber

current_state: AgentLifecycleState

previous_state: Option<AgentLifecycleState>

transition_timeout: TransitionTimeout

drain_timeout: DrainTimeout

pending_requests: PendingRequestCount

failure_reason: Option<FailureReason>

Implementations

impl AgentLifecycle

pub fn new( agent_id: AgentId, agent_name: Option<AgentName>, version: AgentVersion, version_number: VersionNumber, ) -> Self

Creates a new agent lifecycle in unloaded state

pub fn transition_to( &mut self, new_state: AgentLifecycleState, failure_reason: Option<FailureReason>, ) -> Result<(), StateTransitionError>

Attempts to transition to a new state

Errors

Returns an error if the state transition is invalid.

pub fn start(&mut self) -> Result<(), StateTransitionError>

Starts the agent (Ready -> Running)

Errors

Returns an error if the agent cannot transition to Running state.

pub fn start_draining(&mut self) -> Result<(), StateTransitionError>

Begins draining the agent (Running -> Draining)

Errors

Returns an error if the agent cannot transition to Draining state.

pub fn stop(&mut self) -> Result<(), StateTransitionError>

Stops the agent (Running/Draining/Ready -> Stopped)

Errors

Returns an error if the agent cannot transition to Stopped state.

pub fn fail( &mut self, reason: FailureReason, ) -> Result<(), StateTransitionError>

Marks agent as failed with reason

Errors

Returns an error if the agent cannot transition to Failed state.

pub fn add_pending_request(&mut self) -> Result<(), StateTransitionError>

Increments pending request count

Errors

Returns an error if too many requests are pending.

pub fn complete_request(&mut self)

Decrements pending request count

pub fn is_ready_to_stop(&self) -> bool

Checks if agent is ready to be fully stopped (no pending requests)

pub fn get_timeout_for_state(&self) -> u64

Gets time-based constraints for current state

Trait Implementations

impl Clone for AgentLifecycle

fn clone(&self) -> AgentLifecycle

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AgentLifecycle

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for AgentLifecycle

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for AgentLifecycle

impl PartialEq for AgentLifecycle

fn eq(&self, other: &AgentLifecycle) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for AgentLifecycle

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for AgentLifecycle