diff --git a/tools/enums.go b/tools/enums.go index a1d52d0..ba57e06 100644 --- a/tools/enums.go +++ b/tools/enums.go @@ -172,6 +172,7 @@ const ( PB_ADMIRALTY_CONFIG PB_MINIO_CONFIG PB_CLOSE_SEARCH + PB_ARGO_KUBE_EVENT NONE ) @@ -199,13 +200,15 @@ func GetActionString(ss string) PubSubAction { return PB_MINIO_CONFIG case "close_search": return PB_CLOSE_SEARCH + case "argo_kube_event": + return PB_ARGO_KUBE_EVENT default: return NONE } } var path = []string{"search", "search_response", "create", "update", "delete", "planner", "close_planner", - "considers", "admiralty_config", "minio_config", "close_search"} + "considers", "admiralty_config", "minio_config", "close_search", "argo_kube_event"} func (m PubSubAction) String() string { return strings.ToUpper(path[m]) diff --git a/tools/nats_caller.go b/tools/nats_caller.go index 1a4648d..fb2072e 100644 --- a/tools/nats_caller.go +++ b/tools/nats_caller.go @@ -27,7 +27,7 @@ type NATSResponse struct { type NATSMethod int var meths = []string{"remove execution", "create execution", "planner execution", "discovery", - "workflow event", "argo kube event", "create resource", "remove resource", + "workflow event", "create resource", "remove resource", "propalgation event", "search event", "confirm event", } @@ -38,7 +38,6 @@ const ( DISCOVERY WORKFLOW_EVENT - ARGO_KUBE_EVENT CREATE_RESOURCE REMOVE_RESOURCE @@ -55,7 +54,7 @@ func (n NATSMethod) String() string { // NameToMethod returns the NATSMethod enum value from a string 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, CREATE_RESOURCE, REMOVE_RESOURCE, PROPALGATION_EVENT, SEARCH_EVENT, CONFIRM_EVENT} { if strings.Contains(strings.ToLower(v.String()), strings.ToLower(name)) { return v