🥮 mooncakes.io

    colmugx/posoco/kernel does not have a README file

    CallId

    source
    pub(all) struct CallId {
      value : String
    } derive(Eq, Hash, 
    Debug    )

    Stable identifier for a single tool call requested by the assistant. The reducer and scheduler only ever compare/store this string; it is opaque to the Kernel and is produced by the model adapter or by the host.

    CallId::checked

    source
    fn CallId::checked(value : String) -> Result[CallId, String]

    Construct a CallId. Empty strings are rejected — an empty id would make correlation ambiguous. The Kernel invariant treats a missing/empty call id in a streamed completion as ModelParseFailure, not as a usable call.

    CallId::equal

    source
    fn CallId::equal(CallId, CallId) -> Bool

    CallId::hash

    source
    fn CallId::hash(self : CallId) -> Int

    CallId::hash_combine

    source
    fn CallId::hash_combine(CallId, Hasher) -> Unit

    CallId::not_equal

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

    CallId::to_repr

    source

    CallId::to_string

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

    CallId::unchecked

    source
    fn CallId::unchecked(value : String) -> CallId

    Internal constructor used by Kernel tests and by callers that have already validated the string. Production callers should prefer CallId::checked and handle the typed rejection.

    CancelDisposition

    source
    pub(all) enum CancelDisposition {
      Propagated
      NotPropagated
      AlreadySettled
    } derive(Eq, 
    Debug    )

    What an adapter reports after a CancelOutstanding effect. The reducer never waits for this.

    CancelDisposition::equal

    source

    CancelDisposition::not_equal

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

    CancelDisposition::output

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

    CancelDisposition::to_repr

    source

    CancelDisposition::to_string

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

    CancelReason

    source
    pub(all) enum CancelReason {
      HostRequested(detail~ : String?)
      DeadlineReached
    } derive(Eq, 
    Debug    )

    Why a Run was cancelled.

    CancelReason::equal

    source

    CancelReason::not_equal

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

    CancelReason::output

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

    CancelReason::to_repr

    source

    CancelReason::to_string

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

    CatalogVersion

    source
    pub(all) struct CatalogVersion {
      value : Int
    } derive(Eq, 
    Debug    )

    Catalog version — bumped every time a snapshot is built. The reducer and executor correlate CallModel and ExecuteTool effects back to the exact snapshot version the model was prompted against; a mismatch is a kernel invariant failure (InvariantViolation::StaleSnapshot).

    CatalogVersion::CatalogVersion

    source
    fn CatalogVersion::CatalogVersion(value : Int) -> CatalogVersion

    Contract: the canonical constructor wraps its argument unchanged.

    CatalogVersion::equal

    source

    CatalogVersion::not_equal

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

    CatalogVersion::output

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

    CatalogVersion::to_int

    source
    fn CatalogVersion::to_int(self : CatalogVersion) -> Int

    Contract: projection identity — to_int exposes the wrapped version unchanged.

    CatalogVersion::to_repr

    source

    CatalogVersion::to_string

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

    CompactMode

    source
    pub(all) enum CompactMode {
      NewThread
      Replace
      Append
    } derive(Eq)

    How posoco applies the result of ModelPort::compact.
    impl Show for CompactMode

    CompactMode::equal

    source
    fn CompactMode::equal(CompactMode, CompactMode) -> Bool

    CompactMode::not_equal

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

    CompactMode::output

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

    CompactMode::to_string

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

    CompactResult

    source
    pub(all) struct CompactResult {
      compacted_messages : Array[Message]
      mode : CompactMode
    } derive(Eq)

    Return value of ModelPort::compact.

    CompactResult::equal

    source

    CompactResult::not_equal

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

    CompactResult::output

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

    CompactResult::to_string

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

    CompactTrigger

    source
    pub(all) enum CompactTrigger {
      Auto
      Manual
    } derive(Eq, 
    Debug    )

    What triggered a compact. Advisory — modelport may ignore.

    CompactTrigger::equal

    source

    CompactTrigger::not_equal

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

    CompactTrigger::output

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

    CompactTrigger::to_repr

    source

    CompactTrigger::to_string

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

    Completion

    source
    pub(all) struct Completion {
      message : CompletionPayload
      usage : Usage?
    } derive(Eq, 
    Debug    )

    A completed assistant step. The message field is the canonical assistant message that the reducer appends to the transcript; tool calls and reasoning live there (single source of truth, ADR §2.11). The usage field reports token consumption observed for this step, which the reducer may aggregate into the Run budget.

    Construction note: do NOT build this by hand in production code. The from_assistant_message constructor enforces the invariant that the message payload is consistent (assistant role, no ToolMessage shape, etc.).

    Completion::Completion

    source
    fn Completion::Completion(content~ : Array[Content], tool_calls~ : Array[ToolCall], reasoning~ : Reasoning?, finish_reason~ : FinishReason, usage~ : Usage?) -> Completion

    Build an Completion from its parts. The reducer constructs this from a ModelCompleted input after parsing the model adapter's wire representation.

    Completion::equal

    source
    fn Completion::equal(Completion, Completion) -> Bool

    Completion::finish_reason

    source
    fn Completion::finish_reason(self : Completion) -> FinishReason

    Returns the finish reason. Length is preserved as a distinct variant so the reducer can refuse to emit ExecuteTool effects for a truncated completion (ADR §2.7, M0 StreamAccumulator::to_response behaviour).

    Completion::has_tool_calls

    source
    fn Completion::has_tool_calls(self : Completion) -> Bool

    Convenience: does this completion request any tool calls?

    Completion::not_equal

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

    Completion::to_repr

    source

    Completion::tool_calls

    source
    fn Completion::tool_calls(self : Completion) -> Array[ToolCall]

    Returns the tool calls in source order (already a copy of the internal array).

    CompletionPayload

    source
    pub(all) struct CompletionPayload {
      content : Array[Content]
      tool_calls : Array[ToolCall]
      reasoning : Reasoning?
      finish_reason : FinishReason
    } derive(Eq, 
    Debug    )

    Re-flattened assistant payload used inside Completion. We cannot reuse Message::AssistantMessage directly because that variant already carries finish_reason; the completion's message field is the transcript entry, while the usage lives at the completion level. This struct mirrors only the fields that travel together as the assistant's contribution to a single step.

    CompletionPayload::equal

    source

    CompletionPayload::not_equal

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

    CompletionPayload::to_repr

    source

    Content

    source
    pub(all) enum Content {
      Text(String)
      Image(media_type~ : String, data~ : String)
    } derive(Eq, 
    Debug    )

    Canonical content block. Text is the common case; Image carries a stable media-type identifier plus opaque payload data (base64, URL, or an adapter-managed handle — the Kernel does not interpret it).
    impl Show for Content

    Content::equal

    source
    fn Content::equal(Content, Content) -> Bool

    Content::not_equal

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

    Content::output

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

    Content::to_repr

    source

    Content::to_string

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

    ContextPressure

    source
    pub(all) struct ContextPressure {
      window_tokens : Int?
      occupancy_tokens : Int?
      compact_threshold : Double
    } derive(Eq, 
    Debug    )

    Context-pressure advisory for a model-side call. Posoco resolves the effective window and threshold per turn (host config > provider report > core default) and tracks the latest verified occupancy; compact is the call that needs these numbers, so the pump attaches them to the InvocationScope instead of leaving modelports to re-estimate from characters. Read-only for ports; absent dimensions are genuinely unknown and must not be guessed.

    ContextPressure::equal

    source

    ContextPressure::not_equal

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

    ContextPressure::to_repr

    source

    EffectId

    source
    pub(all) struct EffectId {
      value : Int
    } derive(Eq, Hash, 
    Debug    )

    Identifier for a single declared Effect. Monotonic per Run. Each completion input must correlate to a pending effect with this id; a mismatch is InvariantViolation::StaleCorrelation.
    impl Show for EffectId

    EffectId::equal

    source
    fn EffectId::equal(EffectId, EffectId) -> Bool

    EffectId::first

    source
    fn EffectId::first() -> EffectId

    Contract: the counter origin is exactly 1 (strictly positive start).

    EffectId::hash

    source
    fn EffectId::hash(self : EffectId) -> Int

    EffectId::hash_combine

    source
    fn EffectId::hash_combine(EffectId, Hasher) -> Unit

    EffectId::next

    source
    fn EffectId::next(self : EffectId) -> EffectId

    Contract: strictly monotonic — the next id is exactly the current id plus 1, so ids never repeat going forward.

    EffectId::not_equal

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

    EffectId::output

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

    EffectId::to_int

    source
    fn EffectId::to_int(self : EffectId) -> Int

    Contract: projection identity — to_int exposes the underlying counter unchanged.

    EffectId::to_repr

    source

    EffectId::to_string

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

    ExecutionPolicy

    source
    pub(all) enum ExecutionPolicy {
      Sequential
      Parallel
      Exclusive
    } derive(Eq, 
    Debug    )

    How a tool may be batched with other tools in the same model completion.

    • Sequential: occupies a single-element wave. Safe default; file/shell side effects never race.
    • Parallel: may share a wave with adjacent Parallel calls.
    • Exclusive: forms a barrier before and after; never shares a wave.

    Sequential is the safe default. Products opt into Parallel only for tools whose effects are independently safe, and use Exclusive at a visible side-effect boundary.

    ExecutionPolicy::equal

    source

    ExecutionPolicy::not_equal

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

    ExecutionPolicy::output

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

    ExecutionPolicy::to_repr

    source

    ExecutionPolicy::to_string

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

    FinishReason

    source
    pub(all) enum FinishReason {
      Stop
      Length
      ToolCalls
      Other(String)
    } derive(Eq, 
    Debug    )

    Why the assistant finished a step. It is owned by the assistant message (per ADR §2.11: single source of truth).

    Length is preserved as a distinct variant because the reducer must NOT emit ExecuteTool effects after a length-truncated completion, even if the provider tried to stream partial tool calls.

    FinishReason::equal

    source

    FinishReason::not_equal

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

    FinishReason::output

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

    FinishReason::to_repr

    source

    FinishReason::to_string

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

    InvocationScope

    source
    pub(all) struct InvocationScope {
      session_id : SessionId
      run_id : RunId
      effect_id : EffectId?
      pressure : ContextPressure?
    } derive(Eq, 
    Debug    )

    Invocation identity for a single model-side call (ModelPort::chat / ModelPort::compact, and their Runtime correspondences). Constructed by posoco at the effect-interpretation layer and passed down unchanged; ports and hosts MUST treat it as read-only.

    This is the canonical answer to "which session/run is this call serving": adapters that key behaviour on session identity (continuity, telemetry, cost attribution, per-session policy) read it from here instead of smuggling it through messages or config.

    Invariants:
    • session_id / run_id always identify the Run that issued the call, including compact (compact is host-driven but still scoped to a Run).
    • effect_id is Some iff the call executes a reducer-allocated CallModel effect; it is None for compact, which is not an effect. Hosts that propagate cancellation key in-flight model calls by this id, mirroring the tool side's EffectContext.effect_id.
    • pressure is Some only where posoco has a reading worth sharing (the compact path); ports treat it as advisory read-only input.

    InvocationScope::equal

    source

    InvocationScope::not_equal

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

    InvocationScope::to_repr

    source

    Message

    source
    pub(all) enum Message {
      SystemMessage(content~ : Array[Content])
      UserMessage(content~ : Array[Content])
      AssistantMessage(content~ : Array[Content], tool_calls~ : Array[ToolCall], reasoning~ : Reasoning?, finish_reason~ : FinishReason)
      ToolMessage(call_id~ : CallId, tool_name~ : ToolName, outcome~ : ToolOutcome)
    } derive(Eq, 
    Debug    )

    Canonical conversation message. The role determines which payload is legal, making invalid role/payload combinations unrepresentable.

    Invariants:
    • SystemMessage / UserMessage never carry tool calls.
    • AssistantMessage is the ONLY variant that carries tool calls, the ONLY variant that carries reasoning.
    • ToolMessage is the ONLY variant that carries a call_id correlation and a ToolOutcome. It never carries tool calls.

    Message::equal

    source
    fn Message::equal(Message, Message) -> Bool

    Message::not_equal

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

    Message::to_repr

    source

    ModelCallResult

    source
    pub(all) struct ModelCallResult {
      completion : Completion
      processed_messages : Array[Message]
    } derive(Eq)

    Return value of HostRuntime::call_model and ModelPort::chat. Bundles the model completion with the processed message tree.

    The pump ALWAYS replaces the transcript body with processed_messages, then appends completion as the new assistant entry.

    ModelCallResult::equal

    source

    ModelCallResult::not_equal

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

    ModelCallResult::output

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

    ModelCallResult::to_string

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

    ModelFailure

    source
    pub(all) enum ModelFailure {
      RequestBuild(reason~ : String)
      Transport(reason~ : String)
      Runtime(reason~ : String)
      Parse(reason~ : String)
      HostRejected(reason~ : String)
      RateLimited(reason~ : String, reset_at_ms~ : Int64?, provider_code~ : String?)
    } derive(Eq, 
    Debug    )

    Categorises why a model step failed (ADR §2.4). The reducer maps this to a FailureReason::Model* variant. Each variant carries a safe bounded label, never a raw provider payload.

    ModelFailure::equal

    source

    ModelFailure::not_equal

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

    ModelFailure::output

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

    ModelFailure::to_repr

    source

    ModelFailure::to_string

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

    NotExecutedReason

    source
    pub(all) enum NotExecutedReason {
      UnknownTool
      SchemaMismatch(json_path~ : String, expected~ : String, actual~ : String)
      RejectedByHook(reason~ : String)
    } derive(Eq, 
    Debug    )

    Discriminator for the reason a tool call was NOT executed even though the model requested it (ADR §2.7).

    • UnknownTool: the requested tool name is not present in the catalog snapshot that was handed to the CallModel effect.
    • SchemaMismatch: the model's arguments parsed successfully but failed validation against the tool's input schema. The diagnostic carries a safe JSON path and type expectation; it never includes the raw argument payload.
    • RejectedByHook: a PipelineHook::before_tool returned Reject; the call was never dispatched and reason is the hook's steering text fed back to the model.

    Malformed-argument cases never reach this variant — they are ModelParseFailure at the reducer boundary (ADR §2.4).

    NotExecutedReason::equal

    source

    NotExecutedReason::not_equal

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

    NotExecutedReason::output

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

    NotExecutedReason::to_repr

    source

    NotExecutedReason::to_string

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

    OwnerId

    source
    pub(all) struct OwnerId {
      value : String
    } derive(Eq, Hash, 
    Debug    )

    Stable identifier for the provider that owns a tool. The Kernel uses this only for owner lookup in the runtime registry; it does not call into the owner through this type.

    OwnerId::checked

    source
    fn OwnerId::checked(value : String) -> Result[OwnerId, String]

    OwnerId::equal

    source
    fn OwnerId::equal(OwnerId, OwnerId) -> Bool

    OwnerId::hash

    source
    fn OwnerId::hash(self : OwnerId) -> Int

    OwnerId::hash_combine

    source
    fn OwnerId::hash_combine(OwnerId, Hasher) -> Unit

    OwnerId::not_equal

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

    OwnerId::to_repr

    source

    OwnerId::to_string

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

    OwnerId::unchecked

    source
    fn OwnerId::unchecked(value : String) -> OwnerId

    Reasoning

    source
    pub(all) struct Reasoning {
      content : String
      raw : Json?
    } derive(Eq, 
    Debug    )

    Reasoning trace produced by the assistant (e.g. DeepSeek deepseek-reasoner chain-of-thought, OpenAI o-series reasoning content). The Kernel never interprets the content; it stores and replays it. None means the assistant produced no reasoning for this step.

    raw is a provider-defined replay payload: OpenAI Responses API reasoning items must be replayed verbatim when the host manually manages conversation state (per the official reasoning guide), so the adapter stores the raw items here. The kernel never interprets it; providers that replay plain content text (DeepSeek, Kimi, OpenAI-compatible) leave it None.
    impl Show for Reasoning

    Reasoning::equal

    source
    fn Reasoning::equal(Reasoning, Reasoning) -> Bool

    Reasoning::not_equal

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

    Reasoning::output

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

    Reasoning::to_repr

    source

    Reasoning::to_string

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

    RunId

    source
    pub(all) struct RunId {
      value : String
    } derive(Eq, Hash, 
    Debug    )

    Stable identifier for a single Run. Supplied by the host in the Start input and carried through every state.
    impl Show for RunId

    RunId::checked

    source
    fn RunId::checked(value : String) -> Result[RunId, String]

    RunId::equal

    source
    fn RunId::equal(RunId, RunId) -> Bool

    RunId::hash

    source
    fn RunId::hash(self : RunId) -> Int

    RunId::hash_combine

    source
    fn RunId::hash_combine(RunId, Hasher) -> Unit

    RunId::not_equal

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

    RunId::output

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

    RunId::to_repr

    source

    RunId::to_string

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

    RunId::unchecked

    source
    fn RunId::unchecked(value : String) -> RunId

    SchemaDiagnostic

    source
    pub(all) struct SchemaDiagnostic {
      json_path : String
      expected : String
      actual : String
    } derive(Eq, 
    Debug    )

    Result of validating parsed tool arguments against a ToolDef's input schema. The validator (T05) returns this; the reducer (T03) maps Err into a ToolOutcome::NotExecuted(SchemaMismatch) carrying the original call id.

    The diagnostic deliberately excludes the raw argument payload; it reports only a JSON path and a type expectation, so that prompts and tool arguments never leak into logs.

    SchemaDiagnostic::equal

    source

    SchemaDiagnostic::not_equal

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

    SchemaDiagnostic::output

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

    SchemaDiagnostic::to_repr

    source

    SchemaDiagnostic::to_string

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

    SessionId

    source
    pub(all) struct SessionId {
      value : String
    } derive(Eq, Hash, 
    Debug    )

    Stable identifier for a product session. The Kernel never opens or materializes session storage; it carries this identity through effects, journal entries, and committed event envelopes.

    SessionId::checked

    source
    fn SessionId::checked(value : String) -> Result[SessionId, String]

    SessionId::equal

    source
    fn SessionId::equal(SessionId, SessionId) -> Bool

    SessionId::hash

    source
    fn SessionId::hash(self : SessionId) -> Int

    SessionId::hash_combine

    source
    fn SessionId::hash_combine(SessionId, Hasher) -> Unit

    SessionId::not_equal

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

    SessionId::to_repr

    source

    SessionId::to_string

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

    SessionId::unchecked

    source
    fn SessionId::unchecked(value : String) -> SessionId

    ToolCall

    source
    pub(all) struct ToolCall {
      call_id : CallId
      name : ToolName
      arguments : Json
    } derive(Eq, 
    Debug    )

    Tool arguments as parsed JSON. This is the post-parsing representation: if the model stream produced malformed JSON, the reducer has already terminated the Run with ModelParseFailure before this type is constructed. Therefore any ToolCall reaching the scheduler has well-formed arguments, but the arguments may still fail the catalog schema (handled separately as NotExecuted(SchemaMismatch)).
    impl Show for ToolCall

    ToolCall::equal

    source
    fn ToolCall::equal(ToolCall, ToolCall) -> Bool

    ToolCall::not_equal

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

    ToolCall::output

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

    ToolCall::to_repr

    source

    ToolCall::to_string

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

    ToolDef

    source
    pub(all) struct ToolDef {
      name : ToolName
      description : String
      input_schema : Json
      owner : OwnerId
      policy : ExecutionPolicy
      provenance : String?
    } derive(Eq, 
    Debug    )

    A single tool's definition as the model and the executor see it. Owned by the catalog snapshot (T05), not by individual providers.
    impl Show for ToolDef

    ToolDef::ToolDef

    source
    fn ToolDef::ToolDef(name~ : ToolName, description~ : String, input_schema~ : Json, owner~ : OwnerId, policy~ : ExecutionPolicy, provenance~ : String?) -> ToolDef

    Internal builder used by the catalog. Most fields are required; provenance is optional. The catalog builder (T05) validates the schema and policy before constructing this, so by the time a ToolDef reaches the reducer, it has already passed composition.

    ToolDef::equal

    source
    fn ToolDef::equal(ToolDef, ToolDef) -> Bool

    ToolDef::not_equal

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

    ToolDef::output

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

    ToolDef::to_repr

    source

    ToolDef::to_string

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

    ToolName

    source
    pub(all) struct ToolName {
      value : String
    } derive(Eq, Hash, 
    Debug    )

    A tool name as it appears in the catalog (call-visible name). The Kernel uses this only for lookup in the catalog snapshot; it never re-parses or re-normalizes it.

    ToolName::checked

    source
    fn ToolName::checked(value : String) -> Result[ToolName, String]

    ToolName::equal

    source
    fn ToolName::equal(ToolName, ToolName) -> Bool

    ToolName::hash

    source
    fn ToolName::hash(self : ToolName) -> Int

    ToolName::hash_combine

    source
    fn ToolName::hash_combine(ToolName, Hasher) -> Unit

    ToolName::not_equal

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

    ToolName::to_repr

    source

    ToolName::to_string

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

    ToolName::unchecked

    source
    fn ToolName::unchecked(value : String) -> ToolName

    ToolOutcome

    source
    pub(all) enum ToolOutcome {
      Success(content~ : String, structured~ : Json?)
      ToolReportedError(content~ : String, structured~ : Json?)
      RuntimeFailure(error_category~ : String, message~ : String)
      NotExecuted(reason~ : NotExecutedReason, original_call_id~ : CallId)
    } derive(Eq, 
    Debug    )

    Outcome of a single tool invocation (ADR §2.4, §2.11).

    Variants:
    • Success: tool ran and returned structured data. content is the plain-text result sent to the model by the built-in adapters and used for transcripts. structured is an optional machine-readable payload preserved in the kernel transcript, TurnEvent::ToolCallResult, and session snapshots for observers/UIs; the built-in adapters do not send it to the model. Structured objects follow a reserved summary : String field convention for one-line UI summaries.
    • ToolReportedError: tool ran and reported a business-level failure. The Run continues; the failure is fed back to the model as a normal tool message.
    • RuntimeFailure: tool did not run to completion — adapter raised a RuntimeError. Still non-terminal for the Run.
    • NotExecuted: model requested a tool that was not executed (unknown name, parseable-but-schema-invalid args, or a before_tool hook rejection). The original call id is preserved so the model can correlate the feedback.

    There is deliberately no boolean is_error field here. The variant tag IS the error status.
    impl Show for ToolOutcome

    ToolOutcome::equal

    source
    fn ToolOutcome::equal(ToolOutcome, ToolOutcome) -> Bool

    ToolOutcome::is_failure

    source
    fn ToolOutcome::is_failure(self : ToolOutcome) -> Bool

    Whether the outcome represents a non-success path (any variant other than Success). Product adapters may use this for presentation, while canonical control flow pattern-matches the outcome exhaustively.

    ToolOutcome::not_equal

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

    ToolOutcome::output

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

    ToolOutcome::summary

    source
    fn ToolOutcome::summary(self : ToolOutcome) -> String

    Single-line summary that excludes raw payloads. Used by Show and by any debug/log surface, so that prompts and tool arguments never leak.

    ToolOutcome::to_repr

    source

    ToolOutcome::to_string

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

    Transcript

    source
    pub(all) struct Transcript {
      messages : Array[Message]
    } derive(Eq, 
    Debug    )

    Canonical conversation transcript. Every transition produces a fresh array (the reducer never mutates caller-owned arrays, ADR §2.10). The reducer is the only writer.

    Transcript::append

    source
    fn Transcript::append(self : Transcript, message : Message) -> Transcript

    Returns a new transcript with message appended. The original transcript is not mutated (ADR §2.10).

    Transcript::append_all

    source
    fn Transcript::append_all(self : Transcript, messages : Array[Message]) -> Transcript

    Returns a new transcript with messages appended in order.

    Transcript::empty

    source
    fn Transcript::empty() -> Transcript

    Transcript::equal

    source
    fn Transcript::equal(Transcript, Transcript) -> Bool

    Transcript::from_array

    source
    fn Transcript::from_array(messages : Array[Message]) -> Transcript

    Transcript::length

    source
    fn Transcript::length(self : Transcript) -> Int

    Returns the number of messages.

    Transcript::messages_snapshot

    source
    fn Transcript::messages_snapshot(self : Transcript) -> Array[Message]

    Read-only snapshot of the message array. Returns a copy so callers cannot mutate the reducer-owned transcript.

    Transcript::not_equal

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

    Transcript::to_repr

    source

    TurnId

    source
    pub(all) struct TurnId {
      value : String
    } derive(Eq, Hash, 
    Debug    )

    Identifier for a single turn within a Run. A Run may contain multiple turns (initial prompt + follow-ups); turns never outlive their Run. follow_up allocates a new TurnId under the same RunId.
    impl Show for TurnId

    TurnId::checked

    source
    fn TurnId::checked(value : String) -> Result[TurnId, String]

    TurnId::equal

    source
    fn TurnId::equal(TurnId, TurnId) -> Bool

    TurnId::hash

    source
    fn TurnId::hash(self : TurnId) -> Int

    TurnId::hash_combine

    source
    fn TurnId::hash_combine(TurnId, Hasher) -> Unit

    TurnId::not_equal

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

    TurnId::output

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

    TurnId::to_repr

    source

    TurnId::to_string

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

    TurnId::unchecked

    source
    fn TurnId::unchecked(value : String) -> TurnId

    Usage

    source
    pub(all) struct Usage {
      input_tokens : Int?
      output_tokens : Int?
      total_tokens : Int?
      cached_input_tokens : Int?
      uncached_input_tokens : Int?
    } derive(Eq, 
    Debug    )

    Token usage reported by the model for a single step. The Kernel only counts what is actually reported; absent dimensions are None, never silently coerced to 0 (ADR §2.9 — unknown usage is never reported as 0).
    impl Show for Usage

    Usage::equal

    source
    fn Usage::equal(Usage, Usage) -> Bool

    Usage::not_equal

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

    Usage::output

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

    Usage::to_repr

    source

    Usage::to_string

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

    Usage::validate

    source
    fn Usage::validate(self : Usage) -> Result[Unit, String]

    Validate provider-reported token usage before it enters the reducer.

    Every field is optional because providers omit different dimensions, but a reported value is always a count and therefore must be non-negative. Keep this check here as the single canonical usage invariant so every host adapter applies exactly the same rule.

    Source Files

    Powered by MoonBit

    Site sourceReport issuePackagesBuild queueSkillsStatistics

    © 2026 mooncakes.io