operator

Operator control workflows for pause/resume/drain/replay orchestration.

Types

Action

Operator action.

pub type Action {
  Pause(reason: String)
  Resume(reason: String)
  Drain(reason: String)
  Replay(from_stage: String, reason: String)
}

Constructors

```
Pause(reason: String)
```
```
Resume(reason: String)
```
```
Drain(reason: String)
```

Replay(from_stage: String, reason: String)

AuditEvent

One operator audit event.

pub type AuditEvent {
  AuditEvent(
    action: Action,
    before: ControlState,
    after: ControlState,
    at_ms: Int,
  )
}

Constructors

AuditEvent(
  action: Action,
  before: ControlState,
  after: ControlState,
  at_ms: Int,
)

ControlState

Operator control state.

pub type ControlState {
  Running
  Paused(reason: String, at_ms: Int)
  Draining(reason: String, at_ms: Int)
  Replaying(from_stage: String, reason: String, at_ms: Int)
}

Constructors

```
Running
```
```
Paused(reason: String, at_ms: Int)
```
```
Draining(reason: String, at_ms: Int)
```

Replaying(from_stage: String, reason: String, at_ms: Int)

Runtime

opaque

Operator runtime.

pub opaque type Runtime

Values

action_label

pub fn action_label(action: Action) -> String

Action label.

apply

pub fn apply(
  runtime: Runtime,
  action: Action,
  at_ms: Int,
) -> Result(Runtime, String)

Apply one operator action.

audit_event_label

pub fn audit_event_label(event: AuditEvent) -> String

Audit-event label.

audits

pub fn audits(runtime: Runtime) -> List(AuditEvent)

Audit events in application order.

can_enqueue

pub fn can_enqueue(runtime: Runtime) -> Bool

Whether new work can be enqueued.

can_start_work

pub fn can_start_work(runtime: Runtime) -> Bool

Whether queued work can be started.

new

pub fn new() -> Runtime

Build one operator runtime.

signature

pub fn signature(runtime: Runtime) -> String

Stable runtime signature.

state

pub fn state(runtime: Runtime) -> ControlState

Current control state.

state_label

pub fn state_label(state: ControlState) -> String

Control-state label.

valid

pub fn valid(runtime: Runtime) -> Bool

Validate operator runtime invariants.