Versions in this module Expand all Collapse all v0 v0.2.0 Jul 14, 2026 v0.1.0 Jun 22, 2026 Changes in this version + type Mailbox interface + Delete func(ctx context.Context, msgID string) error + History func(ctx context.Context, agentID string, limit int) ([]Message, error) + MarkAllRead func(ctx context.Context, agentID string) error + MarkRead func(ctx context.Context, msgID string) error + PendingCounts func(ctx context.Context, agentIDs []string) (map[string]int, error) + Receive func(ctx context.Context, agentID string) ([]Message, error) + Send func(ctx context.Context, msg Message) error + Thread func(ctx context.Context, rootID string) ([]Message, error) + type Message struct + Body string + CreatedAt time.Time + FromAgent string + ID string + Kind MessageKind + ReadAt *time.Time + ReplyTo string + Subject string + TeamID string + ToAgent string + func NewMessage(kind MessageKind, from, to, subject, body string) Message + type MessageKind string + const KindBroadcast + const KindEvent + const KindReply + const KindTask + type SQLiteMailbox struct + func New(database *db.DB, ...) *SQLiteMailbox + func (m *SQLiteMailbox) Delete(ctx context.Context, msgID string) error + func (m *SQLiteMailbox) History(ctx context.Context, agentID string, limit int) ([]Message, error) + func (m *SQLiteMailbox) MarkAllRead(ctx context.Context, agentID string) error + func (m *SQLiteMailbox) MarkRead(ctx context.Context, msgID string) error + func (m *SQLiteMailbox) PendingCounts(ctx context.Context, agentIDs []string) (map[string]int, error) + func (m *SQLiteMailbox) Receive(ctx context.Context, agentID string) ([]Message, error) + func (m *SQLiteMailbox) Send(ctx context.Context, msg Message) error + func (m *SQLiteMailbox) Thread(ctx context.Context, rootID string) ([]Message, error)
Go to main page