New Channel to Clarify Movement

This commit is contained in:
mr
2026-03-18 15:38:22 +01:00
parent 3d22ff40fb
commit 5976795d44

View File

@@ -29,6 +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",
} }
const ( const (
@@ -47,6 +48,10 @@ const (
SEARCH_EVENT SEARCH_EVENT
CONFIRM_EVENT CONFIRM_EVENT
CONSIDERS_EVENT
ADMIRALTY_CONFIG_EVENT
MINIO_CONFIG_EVENT
) )
func (n NATSMethod) String() string { func (n NATSMethod) String() string {
@@ -56,7 +61,8 @@ func (n NATSMethod) String() string {
// NameToMethod returns the NATSMethod enum value from a string // NameToMethod returns the NATSMethod enum value from a 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} {
if strings.Contains(strings.ToLower(v.String()), strings.ToLower(name)) { if strings.Contains(strings.ToLower(v.String()), strings.ToLower(name)) {
return v return v
} }