mldong/jeeflow-core/parser

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

EdgeModel

pub(all) struct EdgeModel {
  id : String
  source_node_id : String
  target_node_id : String
  label : String?
  properties : Map[String, Json]
} derive(Eq)

EdgeModel::equal

source

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

automatically derived

EdgeModel::expr

source

fn EdgeModel::expr(self : EdgeModel) -> String?

EdgeModel::not_equal

source

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

EdgeModel::source_node_id

source

fn EdgeModel::source_node_id(self : EdgeModel) -> String

EdgeModel::target_node_id

source

fn EdgeModel::target_node_id(self : EdgeModel) -> String

NodeModel

source

pub(all) struct NodeModel {
  id : String
  node_type : NodeType
  display_name : String
  properties : Map[String, Json]
} derive(Eq)

NodeModel::assignee

source

fn NodeModel::assignee(self : NodeModel) -> String?

固定参与人

NodeModel::assignment_handler

source

fn NodeModel::assignment_handler(self : NodeModel) -> String?

动态参与人 handler 名

NodeModel::candidate_groups

source

fn NodeModel::candidate_groups(self : NodeModel) -> String?

NodeModel::candidate_users

source

fn NodeModel::candidate_users(self : NodeModel) -> String?

NodeModel::countersign_completion_condition

source

fn NodeModel::countersign_completion_condition(self : NodeModel) -> String?

会签完成条件（顶层属性优先，field 子对象兜底）

NodeModel::countersign_type

source

fn NodeModel::countersign_type(self : NodeModel) -> String

NodeModel::equal

source

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

automatically derived

NodeModel::expr

source

fn NodeModel::expr(self : NodeModel) -> String?

NodeModel::field_permissions

source

fn NodeModel::field_permissions(self : NodeModel) -> Map[String, Int]

字段权限（PERMISSION_* → 1 只读/2 可编辑/3 隐藏，C19）

NodeModel::form_key

source

fn NodeModel::form_key(self : NodeModel) -> String?

NodeModel::is_countersign

source

fn NodeModel::is_countersign(self : NodeModel) -> Bool

NodeModel::not_equal

source

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

NodeModel::perform_type

source

fn NodeModel::perform_type(self : NodeModel) -> Int

会签类型（C4 容错：数字 1/'1'/'ALL'/'COUNTERSIGN' 均认会签，其余 0）

NodeModel::prop_i64

source

fn NodeModel::prop_i64(self : NodeModel, key : String) -> Int64?

NodeModel::prop_str

source

fn NodeModel::prop_str(self : NodeModel, key : String) -> String?

NodeModel::sub_process_name

source

fn NodeModel::sub_process_name(self : NodeModel) -> String?

NodeModel::task_type

source

fn NodeModel::task_type(self : NodeModel) -> Int

NodeType

source

pub(all) enum NodeType {
  Start
  Task
  Decision
  Fork
  Join
  End
  Custom
  SubProcess
  Unknown
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

本档不做归一化 ⇒ 照 spec 写无前缀 task 的定义会落进这里，那是义务 1 未落地的已知后果。

NodeType::as_str

source

fn NodeType::as_str(self : NodeType) -> String

NodeType::equal

source

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

automatically derived

NodeType::from_snaker_type

source

fn NodeType::from_snaker_type(t : String) -> NodeType

NodeType::not_equal

source

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

NodeType::to_repr

source

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

automatically derived

ProcessModel

source

pub(all) struct ProcessModel {
  name : String
  display_name : String
  model_type : String
  expire_time : String?
  persist_mode : String?
  pre_interceptors : String?
  post_interceptors : String?
  rel_table_name : String?
  nodes : Array[NodeModel]
  edges : Array[EdgeModel]
} derive(Eq)

ProcessModel::can_rejected

source

fn ProcessModel::can_rejected(self : ProcessModel, current_id : String, parent_id : String) -> Bool

等同普通节点。

ProcessModel::equal

source

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

automatically derived

ProcessModel::get_end_nodes

source

fn ProcessModel::get_end_nodes(self : ProcessModel) -> Array[NodeModel]

ProcessModel::get_first_task_node

source

fn ProcessModel::get_first_task_node(self : ProcessModel) -> NodeModel?

start 后第一个任务节点

ProcessModel::get_input_edges

source

fn ProcessModel::get_input_edges(self : ProcessModel, node_id : String) -> Array[EdgeModel]

ProcessModel::get_node

source

fn ProcessModel::get_node(self : ProcessModel, id : String) -> NodeModel?

ProcessModel::get_nodes_by_type

source

fn ProcessModel::get_nodes_by_type(self : ProcessModel, t : NodeType) -> Array[NodeModel]

ProcessModel::get_output_edges

source

fn ProcessModel::get_output_edges(self : ProcessModel, node_id : String) -> Array[EdgeModel]

ProcessModel::get_start

source

fn ProcessModel::get_start(self : ProcessModel) -> NodeModel?

ProcessModel::get_target_node

source

fn ProcessModel::get_target_node(self : ProcessModel, edge : EdgeModel) -> NodeModel?

ProcessModel::interceptor_decl

source

fn ProcessModel::interceptor_decl(self : ProcessModel, node : NodeModel?, prop : String) -> String?

不存在 go/py/node 那条「根声明每定义只回查一行」的读放大问题。

ProcessModel::is_first_task_node

source

fn ProcessModel::is_first_task_node(self : ProcessModel, node_id : String) -> Bool

ProcessModel::not_equal

source

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

parse_model

source

fn parse_model(json_str : String) -> ProcessModel raise @mldong/jeeflow-core/error.JeeflowError
JeeflowError

LogicFlow JSON → ProcessModel

unknown_node_warning

source

fn unknown_node_warning(node_id : String, raw_type : String) -> String

判据留在纯函数、副作用留在调用点，两件事各自可测。

Source Files

parser.mbt

Site source Report issue Packages Build queue Skills Statistics

#EdgeModel

#EdgeModel::equal

#EdgeModel::expr

#EdgeModel::not_equal

#EdgeModel::source_node_id

#EdgeModel::target_node_id

#NodeModel

#NodeModel::assignee

#NodeModel::assignment_handler

#NodeModel::candidate_groups

#NodeModel::candidate_users

#NodeModel::countersign_completion_condition

#NodeModel::countersign_type

#NodeModel::equal

#NodeModel::expr

#NodeModel::field_permissions

#NodeModel::form_key

#NodeModel::is_countersign

#NodeModel::not_equal

#NodeModel::perform_type

#NodeModel::prop_i64

#NodeModel::prop_str

#NodeModel::sub_process_name

#NodeModel::task_type

#NodeType

#NodeType::as_str

#NodeType::equal

#NodeType::from_snaker_type

#NodeType::not_equal

#NodeType::to_repr

#ProcessModel

#ProcessModel::can_rejected

#ProcessModel::equal

#ProcessModel::get_end_nodes

#ProcessModel::get_first_task_node

#ProcessModel::get_input_edges

#ProcessModel::get_node

#ProcessModel::get_nodes_by_type

#ProcessModel::get_output_edges

#ProcessModel::get_start

#ProcessModel::get_target_node

#ProcessModel::interceptor_decl

#ProcessModel::is_first_task_node

#ProcessModel::not_equal

#parse_model

#unknown_node_warning

Source Files

EdgeModel

EdgeModel::equal

EdgeModel::expr

EdgeModel::not_equal

EdgeModel::source_node_id

EdgeModel::target_node_id

NodeModel

NodeModel::assignee

NodeModel::assignment_handler

NodeModel::candidate_groups

NodeModel::candidate_users

NodeModel::countersign_completion_condition

NodeModel::countersign_type

NodeModel::equal

NodeModel::expr

NodeModel::field_permissions

NodeModel::form_key

NodeModel::is_countersign

NodeModel::not_equal

NodeModel::perform_type

NodeModel::prop_i64

NodeModel::prop_str

NodeModel::sub_process_name

NodeModel::task_type

NodeType

NodeType::as_str

NodeType::equal

NodeType::from_snaker_type

NodeType::not_equal

NodeType::to_repr

ProcessModel

ProcessModel::can_rejected

ProcessModel::equal

ProcessModel::get_end_nodes

ProcessModel::get_first_task_node

ProcessModel::get_input_edges

ProcessModel::get_node

ProcessModel::get_nodes_by_type

ProcessModel::get_output_edges

ProcessModel::get_start

ProcessModel::get_target_node

ProcessModel::interceptor_decl

ProcessModel::is_first_task_node

ProcessModel::not_equal

parse_model

unknown_node_warning