🥮 mooncakes.io

    colmugx/posoco/runtime does not have a README file

    Runtime

    source
    pub(open) trait Runtime {
      async fn call_model(Self, scope : 
    InvocationScope    , messages : ArrayView[
    Message    ], tool_definitions : Array[
    ToolDef    ], call_options : 
    Json    , on_chunk : (
    StreamChunk    ) -> Unit?) -> Result[
    ModelCallResult    , 
    ModelFailure    ]
      async fn execute_tool(Self, ctx : EffectContext) -> 
    ToolOutcome
      async fn cancel_effects(Self, run_id~ : 
    RunId    , effect_ids : Array[
    EffectId    ], reason : 
    CancelReason    ) -> Array[(
    EffectId    , 
    CancelDisposition    )]
      async fn compact(Self, scope : 
    InvocationScope    , messages : ArrayView[
    Message    ], tools : Array[
    ToolDef    ], call_options : 
    Json    , trigger : 
    CompactTrigger    ) -> Result[
    CompactResult    , 
    ModelFailure    ]
    }

    The public effect-execution contract. Mirrors the internal boundary 1:1; Posoco adapts it mechanically (a thin shim packs/unpacks EffectContext), so this trait never grows semantics the internal loop does not have.

    Implementors usually wrap PortRuntime and override only the methods they need (typically execute_tool + cancel_effects); see docs/RUNTIME.md.

    EffectContext

    source

    Stable execution context for a single tool effect. effect_id is the reducer-allocated identity of the ExecuteTool effect — the same id the runtime later receives in cancel_effects. Runtimes that propagate cancellation MUST key their in-flight execution state (e.g. an AbortController) by effect_id, not by execution order or call content.

    EffectContext::EffectContext

    source

    Hosts forwarding an effect must forward this context unchanged. This constructor requires the operation-captured provider and call context.

    EnqueueOutcome

    source
    pub(all) enum EnqueueOutcome {
      Accepted(command_id~ : String)
      RejectedStale(reason~ : String)
      RejectedQueueFull(depth~ : Int)
      AbortAlreadyRequested
      RejectedQueueFailure(reason~ : String)
    } derive(Eq, 
    Debug    )

    Pure result returned by Agent-owned host control operations.

    EnqueueOutcome::equal

    source

    EnqueueOutcome::not_equal

    source
    fn EnqueueOutcome::not_equal(x : EnqueueOutcome, y : EnqueueOutcome) -> Bool

    EnqueueOutcome::output

    source
    fn EnqueueOutcome::output(self : EnqueueOutcome, logger : &Logger) -> Unit

    EnqueueOutcome::to_repr

    source

    EnqueueOutcome::to_string

    source
    fn EnqueueOutcome::to_string(self : EnqueueOutcome) -> String

    PortRuntime

    source
    pub struct PortRuntime {
      // private fields
    }

    PortRuntime::PortRuntime

    source

    PortRuntime::call_model

    source

    PortRuntime::cancel_effects

    source

    PortRuntime::compact

    source

    PortRuntime::execute_tool

    source

    Source Files

    Powered by MoonBit

    Site sourceReport issueModulesSkillsBuild queueStatistics

    © 2026 mooncakes.io