core/oc-lib
6
0
Fork 0
Code Issues 7 Pull Requests Packages Projects Releases Wiki Activity

Fusion + Nats Complement

Browse Source
This commit is contained in:
mr
2026-03-23 11:53:21 +01:00
parent 5b197c91e0
commit 14b449f547
2 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
tools/enums.go
View File

@@ -171,6 +171,7 @@ const (
PB_CONSIDERS PB_CONSIDERS
PB_ADMIRALTY_CONFIG PB_ADMIRALTY_CONFIG
PB_MINIO_CONFIG PB_MINIO_CONFIG
PB_PVC_CONFIG
PB_CLOSE_SEARCH PB_CLOSE_SEARCH
NONE NONE
) )

5
tools/nats_caller.go
View File

@@ -29,7 +29,7 @@ type NATSMethod int
var meths = []string{"remove execution", "create execution", "planner execution", "discovery", var meths = []string{"remove execution", "create execution", "planner execution", "discovery",
"workflow event", "argo kube event", "create resource", "remove resource", "workflow event", "argo kube event", "create resource", "remove resource",
"propalgation event", "search event", "confirm event", "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", "workflow started event", "workflow step done event", "workflow done event",
} }
@@ -53,6 +53,7 @@ const (
CONSIDERS_EVENT CONSIDERS_EVENT
ADMIRALTY_CONFIG_EVENT ADMIRALTY_CONFIG_EVENT
MINIO_CONFIG_EVENT MINIO_CONFIG_EVENT
PVC_CONFIG_EVENT
// Workflow lifecycle events emitted by oc-monitord. // Workflow lifecycle events emitted by oc-monitord.
// oc-scheduler listens to STARTED and DONE to maintain WorkflowExecution state. // 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 { func NameToMethod(name string) NATSMethod {
for _, v := range [...]NATSMethod{REMOVE_EXECUTION, CREATE_EXECUTION, PLANNER_EXECUTION, DISCOVERY, WORKFLOW_EVENT, ARGO_KUBE_EVENT, 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, 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} { WORKFLOW_STARTED_EVENT, WORKFLOW_STEP_DONE_EVENT, WORKFLOW_DONE_EVENT} {
if strings.Contains(strings.ToLower(v.String()), strings.ToLower(name)) { if strings.Contains(strings.ToLower(v.String()), strings.ToLower(name)) {
return v return v