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

Planner

Browse Source
This commit is contained in:
mr
2026-02-23 09:20:00 +01:00
parent 9afbbb5c82
commit da8b8ec397
2 changed files with 6 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
tools/enums.go
View File

@@ -193,7 +193,7 @@ type PubSubAction int
const ( const (
PB_SEARCH PubSubAction = iota PB_SEARCH PubSubAction = iota
PB_SEARCH_RESPONSE PB_PLANNER
PB_CREATE PB_CREATE
PB_UPDATE PB_UPDATE
PB_DELETE PB_DELETE
@@ -210,14 +210,14 @@ func GetActionString(ss string) PubSubAction {
return PB_UPDATE return PB_UPDATE
case "delete": case "delete":
return PB_DELETE return PB_DELETE
case "search_response": case "planner":
return PB_SEARCH_RESPONSE return PB_PLANNER
default: default:
return NONE return NONE
} }
} }
var path = []string{"search", "search_response", "create", "update", "delete"} var path = []string{"search", "planner", "create", "update", "delete"}
func (m PubSubAction) String() string { func (m PubSubAction) String() string {
return strings.ToUpper(path[m]) return strings.ToUpper(path[m])

5
tools/nats_caller.go
View File

@@ -27,7 +27,7 @@ type NATSMethod int
var meths = []string{"remove execution", "create execution", "discovery", var meths = []string{"remove execution", "create execution", "discovery",
"workflow event", "create resource", "remove resource", "workflow event", "create resource", "remove resource",
"propalgation event", "search event", "get planner", "propalgation event", "search event",
} }
const ( const (
@@ -41,7 +41,6 @@ const (
PROPALGATION_EVENT PROPALGATION_EVENT
SEARCH_EVENT SEARCH_EVENT
PLANNER_EVENT
) )
func (n NATSMethod) String() string { func (n NATSMethod) String() string {
@@ -51,7 +50,7 @@ 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_EXECTUTION, DISCOVERY, WORKFLOW_EVENT, for _, v := range [...]NATSMethod{REMOVE_EXECUTION, CREATE_EXECTUTION, DISCOVERY, WORKFLOW_EVENT,
CREATE_RESOURCE, REMOVE_RESOURCE, PROPALGATION_EVENT, SEARCH_EVENT, PLANNER_EVENT} { CREATE_RESOURCE, REMOVE_RESOURCE, PROPALGATION_EVENT, SEARCH_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
} }