session

Minimal typed session actor model for Phase 2.

Types

InboxEvent

Typed inbox events handled by one live-session actor.

pub type InboxEvent {
  Connect(route: String, csrf_token: String, now_ms: Int)
  Reconnect(route: String, now_ms: Int)
  Increment
  Decrement
  Ack(ref: String)
  Heartbeat(now_ms: Int)
  Tick(now_ms: Int)
  Crash(reason: String)
  Restart(now_ms: Int)
  Shutdown(reason: String)
}

Constructors

Connect(route: String, csrf_token: String, now_ms: Int)

```
Reconnect(route: String, now_ms: Int)
```
```
Increment
```
```
Decrement
```
```
Ack(ref: String)
```
```
Heartbeat(now_ms: Int)
```
```
Tick(now_ms: Int)
```
```
Crash(reason: String)
```
```
Restart(now_ms: Int)
```
```
Shutdown(reason: String)
```

InboxMessage

Typed inbox envelope that identifies the sender process id.

pub type InboxMessage {
  InboxMessage(owner: String, event: InboxEvent)
}

Constructors

InboxMessage(owner: String, event: InboxEvent)

OutboxMessage

Typed outbox records emitted from the actor.

pub type OutboxMessage {
  OutboxPatch(PatchEnvelope)
  OutboxTelemetry(TelemetryEvent)
}

Constructors

```
OutboxPatch(PatchEnvelope)
```
```
OutboxTelemetry(TelemetryEvent)
```

PatchEnvelope

Patch queued by the session actor.

pub type PatchEnvelope {
  PatchEnvelope(ref: String, patch: diff.Patch)
}

Constructors

PatchEnvelope(ref: String, patch: diff.Patch)

ReconnectPolicy

Reconnect strategy after disconnect/crash.

pub type ReconnectPolicy {
  Rehydrate
  Remount
}

Constructors

```
Rehydrate
```
```
Remount
```

Session

opaque

Internal state of one session actor.

pub opaque type Session

TelemetryEvent

Telemetry emitted by one session actor.

pub type TelemetryEvent {
  SessionMounted(session_id: String, route: String)
  SessionRehydrated(session_id: String, route: String)
  SessionRemounted(session_id: String, route: String)
  CounterUpdated(session_id: String, value: Int)
  PatchQueued(session_id: String, ref: String)
  PatchAcked(session_id: String, ref: String)
  HeartbeatReceived(session_id: String, deadline_ms: Int)
  HeartbeatTimedOut(session_id: String, now_ms: Int)
  SessionCrashed(session_id: String, reason: String)
  SessionRestarted(session_id: String)
  SessionShutdown(session_id: String, reason: String)
  OwnershipRejected(session_id: String, owner: String)
  EventIgnored(session_id: String, event: String)
}

Constructors

SessionMounted(session_id: String, route: String)

SessionRehydrated(session_id: String, route: String)

SessionRemounted(session_id: String, route: String)

CounterUpdated(session_id: String, value: Int)

PatchQueued(session_id: String, ref: String)

PatchAcked(session_id: String, ref: String)

HeartbeatReceived(session_id: String, deadline_ms: Int)

HeartbeatTimedOut(session_id: String, now_ms: Int)

SessionCrashed(session_id: String, reason: String)

```
SessionRestarted(session_id: String)
```

SessionShutdown(session_id: String, reason: String)

OwnershipRejected(session_id: String, owner: String)

EventIgnored(session_id: String, event: String)

TelemetrySummary

Aggregated telemetry counters for hot-path consumers.

pub type TelemetrySummary {
  TelemetrySummary(
    patch_queued: Int,
    patch_acked: Int,
    session_crashed: Int,
    session_rehydrated: Int,
    session_remounted: Int,
    total_events: Int,
  )
}

Constructors

TelemetrySummary(
  patch_queued: Int,
  patch_acked: Int,
  session_crashed: Int,
  session_rehydrated: Int,
  session_remounted: Int,
  total_events: Int,
)

Values

counter

pub fn counter(session: Session) -> Int

Current counter model used by this minimal actor.

crashed

pub fn crashed(session: Session) -> Bool

True when session has crashed and is waiting for restart.

flush_outbox

pub fn flush_outbox(
  session: Session,
) -> #(Session, List(OutboxMessage))

Drain the outbox and clear it from state.

handle

pub fn handle(session: Session, message: InboxMessage) -> Session

Handle one typed inbox message.

heartbeat_deadline_ms

pub fn heartbeat_deadline_ms(session: Session) -> Int

Heartbeat deadline timestamp in milliseconds.

id

pub fn id(session: Session) -> String

Session id.

lifecycle

pub fn lifecycle(session: Session) -> typestate.Lifecycle

Lifecycle label.

oldest_pending_patch

pub fn oldest_pending_patch(
  session: Session,
) -> option.Option(PatchEnvelope)

Oldest pending patch waiting for ack, when present.

owner

pub fn owner(session: Session) -> String

Owning server process id.

patch

pub fn patch(patch: PatchEnvelope) -> diff.Patch

Extract patch payload.

patch_ref

pub fn patch_ref(patch: PatchEnvelope) -> String

Extract patch reference.

pending_patch_count

pub fn pending_patch_count(session: Session) -> Int

Number of pending patches waiting for ack.

pending_patches

pub fn pending_patches(session: Session) -> List(PatchEnvelope)

Pending patches waiting for ack, in emit order.

reconnect_policy

pub fn reconnect_policy(session: Session) -> ReconnectPolicy

Current reconnect policy.

start

pub fn start(
  id: String,
  owner: String,
  reconnect_policy: ReconnectPolicy,
  now_ms: Int,
  timeout_ms: Int,
) -> Session

Start a new disconnected session actor state.

summary_patch_acked

pub fn summary_patch_acked(summary: TelemetrySummary) -> Int

patch_acked event count.

summary_patch_queued

pub fn summary_patch_queued(summary: TelemetrySummary) -> Int

patch_queued event count.

summary_session_crashed

pub fn summary_session_crashed(summary: TelemetrySummary) -> Int

session_crashed event count.

summary_session_rehydrated

pub fn summary_session_rehydrated(
  summary: TelemetrySummary,
) -> Int

session_rehydrated event count.

summary_session_remounted

pub fn summary_session_remounted(
  summary: TelemetrySummary,
) -> Int

session_remounted event count.

summary_total_events

pub fn summary_total_events(summary: TelemetrySummary) -> Int

Total telemetry event count.

telemetry

pub fn telemetry(session: Session) -> List(TelemetryEvent)

Telemetry records in emit order.

telemetry_count

pub fn telemetry_count(session: Session) -> Int

Number of telemetry events currently held by session state.

telemetry_label

pub fn telemetry_label(event: TelemetryEvent) -> String

Stable telemetry label for assertions and logs.

telemetry_summary

pub fn telemetry_summary(session: Session) -> TelemetrySummary

Aggregated telemetry counters for hot-path extraction.