/** * Outbox commands: send, inbox, ack, ack all, outbox pending, outbox gc * * PRD-024: Agent Outbox Messaging Primitive * * Channel-based agent-to-agent messaging. */ import { Effect } from "effect"; import { MessageService } from "@jamesaphoenix/tx"; import { type Flags } from "../utils/parse.js"; /** * Send a message to a channel. * * Usage: tx msg send [--sender ] [--task ] [--ttl ] [--correlation ] [--metadata '{}'] [--json] */ export declare const send: (pos: string[], flags: Flags) => Effect.Effect; /** * Read messages from a channel's inbox. * This is a pure read — no side effects, no status changes. * * Usage: tx msg inbox [--after ] [--limit ] [--sender ] [--correlation ] [--include-acked] [--json] */ export declare const inbox: (pos: string[], flags: Flags) => Effect.Effect; /** * Ack dispatcher: routes `tx ack all ` or acts as direct ack. * * - `tx msg ack all ` → ackAll * - `tx msg ack ` → direct ack */ export declare const ack: (pos: string[], flags: Flags) => Effect.Effect; /** * Acknowledge all pending messages on a channel. * * Usage: tx msg ack all [--json] */ export declare const ackAll: (pos: string[], flags: Flags) => Effect.Effect; /** * Count pending messages on a channel. * * Usage: tx msg pending [--json] */ export declare const outboxPending: (pos: string[], flags: Flags) => Effect.Effect; /** * Garbage collect old messages. * * Usage: tx msg gc [--acked-older-than ] [--json] */ export declare const outboxGc: (_pos: string[], flags: Flags) => Effect.Effect; /** * Outbox dispatcher: routes `tx outbox ` to the appropriate handler. */ export declare const outbox: (pos: string[], flags: Flags) => Effect.Effect; //# sourceMappingURL=outbox.d.ts.map