Struct TeamEvent 

pub struct TeamEvent {

    pub event: String,
    pub action_type: Option<String>,
    pub version: Option<String>,
    pub git_ref: Option<String>,
    pub role: Option<String>,
    pub task: Option<String>,
    pub recipient: Option<String>,
    pub from: Option<String>,
    pub to: Option<String>,
    pub restart: Option<bool>,
    pub restart_count: Option<u32>,
    pub load: Option<f64>,
    pub working_members: Option<u32>,
    pub total_members: Option<u32>,
    pub session_running: Option<bool>,
    pub reason: Option<String>,
    pub step: Option<String>,
    pub error: Option<String>,
    pub details: Option<String>,
    pub uptime_secs: Option<u64>,
    pub session_size_bytes: Option<u64>,
    pub output_bytes: Option<u64>,
    pub filename: Option<String>,
    pub content_hash: Option<String>,
    pub backend: Option<String>,
    pub success: Option<bool>,
    pub merge_mode: Option<String>,
    pub narration_ratio: Option<f64>,
    pub commit_frequency: Option<f64>,
    pub first_pass_test_rate: Option<f64>,
    pub retry_rate: Option<f64>,
    pub time_to_completion_secs: Option<u64>,
    pub ts: u64,
}

Fields

event: String

action_type: Option<String>

version: Option<String>

git_ref: Option<String>

role: Option<String>

task: Option<String>

recipient: Option<String>

from: Option<String>

to: Option<String>

restart: Option<bool>

restart_count: Option<u32>

load: Option<f64>

working_members: Option<u32>

total_members: Option<u32>

session_running: Option<bool>

reason: Option<String>

step: Option<String>

error: Option<String>

details: Option<String>

uptime_secs: Option<u64>

session_size_bytes: Option<u64>

output_bytes: Option<u64>

filename: Option<String>

content_hash: Option<String>

backend: Option<String>

success: Option<bool>

merge_mode: Option<String>

narration_ratio: Option<f64>

commit_frequency: Option<f64>

first_pass_test_rate: Option<f64>

retry_rate: Option<f64>

time_to_completion_secs: Option<u64>

ts: u64

Implementations

impl TeamEvent

pub fn daemon_started() -> Self

pub fn daemon_reloading() -> Self

pub fn daemon_reloaded() -> Self

pub fn daemon_stopped() -> Self

pub fn daemon_stopped_with_reason(reason: &str, uptime_secs: u64) -> Self

pub fn daemon_heartbeat(uptime_secs: u64) -> Self

pub fn context_exhausted( role: &str, task: Option<u32>, session_size_bytes: Option<u64>, ) -> Self

pub fn loop_step_error(step: &str, error: &str) -> Self

pub fn daemon_panic(reason: &str) -> Self

pub fn task_assigned(role: &str, task: &str) -> Self

pub fn dispatch_fallback_used( role: &str, task: &str, recipient: &str, reason: &str, ) -> Self

pub fn dispatch_overlap_prevented( task_id: u32, blocked_by: &[u32], details: &str, ) -> Self

pub fn dispatch_overlap_skipped( candidate_task_id: u32, conflicting_task_id: &str, conflicting_files: &[String], ) -> Self

pub fn cwd_corrected(role: &str, path: &str) -> Self

pub fn review_nudge_sent(role: &str, task: &str) -> Self

pub fn review_escalated(task: &str, reason: &str) -> Self

pub fn state_reconciliation( role: Option<&str>, task: Option<&str>, correction: &str, ) -> Self

pub fn task_escalated(role: &str, task: &str, reason: Option<&str>) -> Self

pub fn task_stale(role: &str, task: &str, reason: &str) -> Self

pub fn task_aged(task: &str, reason: &str) -> Self

pub fn review_stale(task: &str, reason: &str) -> Self

pub fn task_unblocked(role: &str, task: &str) -> Self

pub fn task_claim_created( role: &str, task: &str, ttl_secs: u64, expires_at: &str, ) -> Self

pub fn task_claim_progress(role: &str, task: &str, progress_type: &str) -> Self

pub fn task_claim_warning(role: &str, task: &str, expires_in_secs: u64) -> Self

pub fn task_claim_expired( role: &str, task: &str, reclaimed: bool, time_held_secs: Option<u64>, ) -> Self

pub fn task_claim_extended(role: &str, task: &str, new_expires_at: &str) -> Self

pub fn scope_fence_violation(role: &str, task_id: u32, details: &str) -> Self

pub fn board_task_archived(task: &str, role: Option<&str>) -> Self

pub fn auto_doctor_action( action_type: &str, task_id: Option<u32>, engineer: Option<&str>, details: &str, ) -> Self

pub fn performance_regression(task: &str, reason: &str) -> Self

pub fn task_completed(role: &str, task: Option<&str>) -> Self

pub fn quality_metrics_recorded(info: &QualityMetricsInfo<'_>) -> Self

pub fn standup_generated(recipient: &str) -> Self

pub fn supervisory_digest_emitted( role: &str, notice_count: u32, suppressed_duplicates: u32, ) -> Self

pub fn retro_generated() -> Self

pub fn pattern_detected(pattern_type: &str, frequency: u32) -> Self

pub fn disk_hygiene_cleanup(summary: &str) -> Self

pub fn member_crashed(role: &str, restart: bool) -> Self

pub fn pane_death(role: &str) -> Self

pub fn pane_respawned(role: &str) -> Self

pub fn shim_disconnect( role: &str, reason: &str, details: &str, expected: bool, ) -> Self

pub fn narration_detected(role: &str, task: Option<u32>) -> Self

pub fn narration_nudged(role: &str, task: Option<u32>) -> Self

pub fn narration_restart(role: &str, task: Option<u32>) -> Self

pub fn narration_rejection( role: &str, task_id: u32, rejection_count: u32, ) -> Self

pub fn tact_cycle_triggered( role: &str, idle_engineers: u32, board_summary: &str, ) -> Self

pub fn tact_tasks_created( role: &str, tasks_created: u32, latency_secs: u64, success: bool, error: Option<&str>, ) -> Self

pub fn context_pressure_warning( role: &str, task: Option<u32>, pressure_score: u64, threshold: u64, output_bytes: u64, ) -> Self

pub fn stall_detected( role: &str, task: Option<u32>, stall_duration_secs: u64, ) -> Self

pub fn stall_detected_with_reason( role: &str, task: Option<u32>, stall_duration_secs: u64, reason: Option<&str>, ) -> Self

pub fn health_changed(role: &str, reason: &str) -> Self

Record a backend health state change for an agent.

reason encodes the transition, e.g. “healthy→unreachable”.

pub fn message_routed(from: &str, to: &str) -> Self

pub fn discord_event_sent(channel: &str, source_event: &str) -> Self

pub fn notification_delivery_sample( from: &str, to: &str, latency_secs: u64, isolation_mode: &str, ) -> Self

pub fn inbox_message_expired( target: &str, from: &str, message_age_secs: u64, ) -> Self

pub fn inbox_message_deduplicated( target: &str, from: &str, signature: u64, ) -> Self

pub fn inbox_batch_delivered( target: &str, message_count: usize, escalation_count: usize, ) -> Self

pub fn backend_quota_exhausted(role: &str, reason: &str) -> Self

pub fn agent_spawned(role: &str) -> Self

pub fn agent_restarted( role: &str, task: &str, reason: &str, restart_count: u32, ) -> Self

pub fn agent_handoff( role: &str, task: &str, reason: &str, success: bool, ) -> Self

pub fn handoff_injected(role: &str, task: &str, reason: &str) -> Self

pub fn task_resumed( role: &str, task: &str, reason: &str, restart_count: u32, ) -> Self

pub fn delivery_failed(role: &str, from: &str, reason: &str) -> Self

pub fn delivery_failed_with_details( role: &str, from: &str, reason: &str, details: Option<&str>, ) -> Self

pub fn task_auto_merged( engineer: &str, task: &str, confidence: f64, files_changed: usize, lines_changed: usize, ) -> Self

pub fn task_auto_merged_with_mode( engineer: &str, task: &str, confidence: f64, files_changed: usize, lines_changed: usize, merge_mode: Option<MergeMode>, ) -> Self

pub fn auto_merge_decision_recorded(info: &AutoMergeDecisionInfo<'_>) -> Self

pub fn auto_merge_post_verify_result( engineer: &str, task: &str, success: Option<bool>, reason: &str, details: Option<&str>, ) -> Self

pub fn task_manual_merged(task: &str) -> Self

pub fn task_manual_merged_with_mode( task: &str, merge_mode: Option<MergeMode>, ) -> Self

pub fn task_merge_failed( engineer: &str, task: &str, merge_mode: Option<MergeMode>, details: &str, ) -> Self

pub fn merge_confidence_scored(info: &MergeConfidenceInfo<'_>) -> Self

Emitted for every completed task to record its merge confidence score.

pub fn verification_phase_changed( info: &VerificationPhaseChangeInfo<'_>, ) -> Self

pub fn verification_evidence_collected( engineer: &str, task: &str, evidence_kind: &str, detail: &str, ) -> Self

pub fn verification_max_iterations_reached( engineer: &str, task: &str, iteration: u32, escalated_to: &str, ) -> Self

pub fn review_escalated_by_role(role: &str, task: &str) -> Self

pub fn pipeline_starvation_detected( idle_engineers: usize, todo_tasks: usize, ) -> Self

pub fn task_reworked(role: &str, task: &str) -> Self

pub fn task_recycled(task_id: u32, cron_expr: &str) -> Self

pub fn barrier_artifact_created( role: &str, filename: &str, content_hash: &str, ) -> Self

pub fn barrier_artifact_read( role: &str, filename: &str, content_hash: &str, ) -> Self

pub fn barrier_violation_attempt( role: &str, filename: &str, reason: &str, ) -> Self

pub fn load_snapshot( working_members: u32, total_members: u32, session_running: bool, ) -> Self

pub fn parity_updated(summary: &ParitySummary) -> Self

pub fn release_succeeded( version: &str, git_ref: &str, tag: &str, notes_path: Option<&str>, ) -> Self

pub fn release_failed( version: Option<&str>, git_ref: Option<&str>, tag: Option<&str>, reason: &str, details: Option<&str>, ) -> Self

pub fn worktree_reconciled(role: &str, branch: &str) -> Self

pub fn worktree_refreshed(role: &str, reason: &str) -> Self

pub fn topology_changed(added: u32, removed: u32, reason: &str) -> Self

Emitted when the daemon reconciles a topology change.

reason contains a human-readable summary (e.g. “+2 added, -1 removed”).

pub fn agent_removed(role: &str, reason: &str) -> Self

Emitted when an agent is removed during a scale-down.

Trait Implementations

impl Clone for TeamEvent

fn clone(&self) -> TeamEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TeamEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for TeamEvent

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for TeamEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.