argo event

This commit is contained in:
mr
2026-03-18 14:46:35 +01:00
parent 1a37a1b4aa
commit c66fbc809e
2 changed files with 6 additions and 4 deletions

View File

@@ -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])

View File

@@ -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