Struct FlowEntry 

pub struct FlowEntry {

    pub handle: String,
    pub goal: String,
    pub status: Arc<Mutex<FlowRunStatus>>,
    pub output: Arc<Mutex<String>>,
    pub cancel: CancellationToken,
    pub stream_tx: Sender<FlowEvent>,
    pub messages: Arc<Mutex<Vec<Message>>>,
    pub iteration: Arc<AtomicU64>,
    pub child_run_id: FlowRunId,
    pub model: String,
    pub started_at: DateTime<Utc>,
    pub compact_lock: Arc<Mutex<()>>,
    pub interjection_tx: Sender<Injection>,
    pub pending_injections: Arc<Mutex<Vec<Injection>>>,
    pub injection_notify: Arc<Notify>,
    pub frame_tx: Sender<StreamFrame>,
}

Fields

handle: String

goal: String

status: Arc<Mutex<FlowRunStatus>>

output: Arc<Mutex<String>>

cancel: CancellationToken

stream_tx: Sender<FlowEvent>

messages: Arc<Mutex<Vec<Message>>>

iteration: Arc<AtomicU64>

child_run_id: FlowRunId

model: String

started_at: DateTime<Utc>

compact_lock: Arc<Mutex<()>>

interjection_tx: Sender<Injection>

pending_injections: Arc<Mutex<Vec<Injection>>>

injection_notify: Arc<Notify>

frame_tx: Sender<StreamFrame>

Trait Implementations

impl Watchable for FlowEntry

fn watch_output( self: Arc<Self>, pattern: String, cancel: CancellationToken, ) -> Pin<Box<dyn Future<Output = WatchResult> + Send>>