Struct TeamManager 

pub struct TeamManager { /* private fields */ }

Implementations

impl TeamManager

pub fn new(data_dir: PathBuf) -> Self

pub async fn insert(&self, team: TeamState) -> Result<TeamState>

pub async fn get(&self, team_id: &str) -> Option<TeamState>

pub async fn list(&self) -> Vec<TeamState>

pub async fn update_member( &self, team_id: &str, member_id: &str, update: impl FnOnce(&mut TeamMemberDescriptor), ) -> Result<TeamState>

pub async fn add_member( &self, team_id: &str, member: TeamMemberDescriptor, ) -> Result<TeamState>

pub async fn append_mailbox_message( &self, team_id: &str, from_member_id: Option<TeamMemberId>, to_member_id: TeamMemberId, kind: TeamMailboxMessageKind, text: String, ) -> Result<TeamState>

pub async fn reserve_pending_mailbox_messages( &self, team_id: &str, member_id: &str, turn_id: &TurnId, ) -> Result<Vec<TeamMailboxMessage>>

Reserve currently pending messages for one active turn without marking them delivered. Reservations are process-local: a crash makes the messages eligible for redelivery, preserving at-least-once delivery.

pub async fn has_pending_mailbox_messages( &self, team_id: &str, member_id: &str, ) -> bool

Whether any undelivered mailbox message is addressed to this member.

Read-only on purpose: unlike Self::reserve_pending_mailbox_messages it takes no reservation, so a waiter can ask “is there anything for me?” without consuming the queue it is about to be woken for.

pub async fn release_mailbox_reservations_for_turn(&self, turn_id: &TurnId)

pub async fn release_mailbox_reservations( &self, turn_id: &TurnId, message_ids: &[String], )

pub async fn mark_mailbox_messages_delivered( &self, team_id: &str, turn_id: &TurnId, message_ids: &[String], ) -> Result<()>

pub async fn set_member_policy_mode( &self, team_id: &str, member_id: &str, policy_mode: PolicyMode, ) -> Result<TeamState>

pub async fn policy_mode_for_thread( &self, thread_id: &str, ) -> Option<PolicyMode>

pub async fn member_for_thread( &self, thread_id: &str, ) -> Option<(TeamId, TeamMemberDescriptor)>

pub async fn complete_member_turn( &self, thread_id: &str, turn_id: &str, status: TeamMemberStatus, final_message: Option<String>, terminal_error: Option<String>, ) -> Result<Option<(TeamId, TeamMemberDescriptor)>>

pub async fn remove(&self, team_id: &str) -> Result<Option<TeamState>>

Trait Implementations

impl Debug for TeamManager

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

Formats the value using the given formatter.

impl Default for TeamManager

fn default() -> Self

Returns the “default value” for a type.