mldong/jeeflow-core/event

mldong/jeeflow-core/event does not have a README file

ProcessEvent

pub(all) struct ProcessEvent {
  event_type : ProcessEventType
  source_id : Int64
  data : @mldong/jeeflow-core/json.FlowData
FlowData
  cc_actor_id : String?
}

ProcessEvent::cc_actor_id

source

fn ProcessEvent::cc_actor_id(self : ProcessEvent) -> String?

ProcessEvent::event_type

source

fn ProcessEvent::event_type(self : ProcessEvent) -> ProcessEventType

ProcessEvent::make

source

fn ProcessEvent::make(event_type : ProcessEventType, source_id : Int64) -> ProcessEvent

ProcessEvent::source_id

source

fn ProcessEvent::source_id(self : ProcessEvent) -> Int64

ProcessEvent::with_cc_actor_id

source

fn ProcessEvent::with_cc_actor_id(self : ProcessEvent, cc_actor_id : String) -> ProcessEvent

ProcessEvent::with_data

source

fn ProcessEvent::with_data(self : ProcessEvent, data : @mldong/jeeflow-core/json.FlowData
FlowData) -> ProcessEvent

ProcessEventType

source

pub(all) enum ProcessEventType {
  ProcessInstanceStart
  ProcessInstanceEnd
  ProcessTaskStart
  CcCreate
  TaskComplete
  TaskReject
  TaskTransfer
  TaskWithdraw
  InstanceTerminated
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

规范名 ↔ 构造子映射（构造子为本栈实际命名，name() 透出 spec §11.3 权威 SCREAMING 名）： 1 PROCESS_INSTANCE_START / 2 PROCESS_INSTANCE_END / 3 PROCESS_TASK_START / 4 CC_CREATE 5 TASK_COMPLETE / 6 TASK_REJECT / 7 TASK_TRANSFER / 8 TASK_WITHDRAW / 9 INSTANCE_TERMINATED

ProcessEventType::code

source

fn ProcessEventType::code(self : ProcessEventType) -> Int

ProcessEventType::equal

source

fn ProcessEventType::equal(ProcessEventType, ProcessEventType) -> Bool

automatically derived

ProcessEventType::from_code

source

fn ProcessEventType::from_code(code : Int) -> ProcessEventType?

ProcessEventType::name

source

fn ProcessEventType::name(self : ProcessEventType) -> String

spec §11.3 规范名（集成层跨语言判据一律用规范名，不得拿数字码当判据）

ProcessEventType::not_equal

source

fn ProcessEventType::not_equal(x : ProcessEventType, y : ProcessEventType) -> Bool

ProcessEventType::to_repr

source

fn ProcessEventType::to_repr(ProcessEventType) -> @moonbitlang/core/debug.Repr
Repr

automatically derived

listener_error_warning

source

fn listener_error_warning(event : ProcessEvent, err : @mldong/jeeflow-core/error.JeeflowError
JeeflowError) -> String

监听器异常隔离的诊断日志文案（F08 裁定完整口径＝「每支 try/catch ＋带原因 ERROR 日志」的后半句；audit8 R19 补齐）。抽纯函数的理由同 engine 的 custom_*_warning：println 的效果在测试里读不回来，判据留在纯函数、副作用留在调用点。

notify

source

async fn notify(event : ProcessEvent, listeners : Array[async (ProcessEvent) -> Unit raise @mldong/jeeflow-core/error.JeeflowError
JeeflowError]) -> Unit raise @mldong/jeeflow-core/error.JeeflowError
JeeflowError