Enum AgentTopic 

pub enum AgentTopic<'a> {
    Sessions,
    Streams,
    Heartbeats,
    Control,
    Memory,
    Audit,
    Registry,
    WorkflowJournal,
    Dlq,
    Custom(&'a Identifier),
}

A well-known agent topic, or a Custom one. Each maps to an Iggy topic name.

Variants

Sessions

The session lane: commands, replies, tool and model records, user turns, lifecycle, and state, keyed by session.

Streams

High-volume chunk streams, collapsed into their response on a timeline.

Heartbeats

Process heartbeats listing the sessions a process holds leases on.

Control

Session control requests, sent by operators only.

Memory

Memory records.

Audit

Policy evidence and other audit records.

Registry

The agent card registry: agents republish their cards here, and the registry read model folds it to the latest card per agent.

WorkflowJournal

The workflow journal: the engine records each step’s outcome here, keyed by the workflow run, so a crashed run resumes by replaying it.

Dlq

The dead-letter topic.

Custom(&'a Identifier)

Any other topic, by Identifier.

Implementations

impl AgentTopic<'_>

pub const fn name(&self) -> Option<&'static str>

The static topic name, or None for Custom.

pub fn as_identifier(&self) -> Identifier

The Iggy Identifier for this topic.

pub fn topic_string(&self) -> String

The topic name as an owned String.

Trait Implementations

impl<'a> Clone for AgentTopic<'a>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<'a> Debug for AgentTopic<'a>

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

Formats the value using the given formatter.

impl<'a> Eq for AgentTopic<'a>

impl<'a> PartialEq for AgentTopic<'a>

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

Equality operator ==.

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

Inequality operator !=.

impl<'a> StructuralPartialEq for AgentTopic<'a>