From 14b449f5473b2e8507ac13aafcc1251f41d7fccb Mon Sep 17 00:00:00 2001 From: mr Date: Mon, 23 Mar 2026 11:53:21 +0100 Subject: [PATCH] Fusion + Nats Complement --- tools/enums.go | 1 + tools/nats_caller.go | 5 +++-- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/tools/enums.go b/tools/enums.go index a1d52d0..cd859cf 100644 --- a/tools/enums.go +++ b/tools/enums.go @@ -171,6 +171,7 @@ const ( PB_CONSIDERS PB_ADMIRALTY_CONFIG PB_MINIO_CONFIG + PB_PVC_CONFIG PB_CLOSE_SEARCH NONE ) diff --git a/tools/nats_caller.go b/tools/nats_caller.go index 51041db..74a5bc1 100644 --- a/tools/nats_caller.go +++ b/tools/nats_caller.go @@ -29,7 +29,7 @@ type NATSMethod int var meths = []string{"remove execution", "create execution", "planner execution", "discovery", "workflow event", "argo kube event", "create resource", "remove resource", "propalgation event", "search event", "confirm event", - "considers event", "admiralty config event", "minio config event", + "considers event", "admiralty config event", "minio config event", "pvc config event", "workflow started event", "workflow step done event", "workflow done event", } @@ -53,6 +53,7 @@ const ( CONSIDERS_EVENT ADMIRALTY_CONFIG_EVENT MINIO_CONFIG_EVENT + PVC_CONFIG_EVENT // Workflow lifecycle events emitted by oc-monitord. // oc-scheduler listens to STARTED and DONE to maintain WorkflowExecution state. @@ -70,7 +71,7 @@ func (n NATSMethod) String() string { func NameToMethod(name string) NATSMethod { for _, v := range [...]NATSMethod{REMOVE_EXECUTION, CREATE_EXECUTION, PLANNER_EXECUTION, DISCOVERY, WORKFLOW_EVENT, ARGO_KUBE_EVENT, CREATE_RESOURCE, REMOVE_RESOURCE, PROPALGATION_EVENT, SEARCH_EVENT, CONFIRM_EVENT, - CONSIDERS_EVENT, ADMIRALTY_CONFIG_EVENT, MINIO_CONFIG_EVENT, + CONSIDERS_EVENT, ADMIRALTY_CONFIG_EVENT, MINIO_CONFIG_EVENT, PVC_CONFIG_EVENT, WORKFLOW_STARTED_EVENT, WORKFLOW_STEP_DONE_EVENT, WORKFLOW_DONE_EVENT} { if strings.Contains(strings.ToLower(v.String()), strings.ToLower(name)) { return v