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

adjust useless line

Browse Source
This commit is contained in:
mr
2026-01-27 09:50:07 +01:00
parent c69069449f
commit d772a703da
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
tools/nats_caller.go
View File

@@ -17,7 +17,7 @@ import (
type NATSMethod int type NATSMethod int
var meths = []string{"remove execution", "create execution", "discovery", var meths = []string{"remove execution", "create execution", "discovery",
"workflow event", "peer discovery", "peer detection"} "workflow event", "peer discovery"}
const ( const (
REMOVE_EXECUTION NATSMethod = iota REMOVE_EXECUTION NATSMethod = iota
@@ -25,7 +25,6 @@ const (
DISCOVERY DISCOVERY
WORKFLOW_EVENT WORKFLOW_EVENT
PEER_DISCOVERY PEER_DISCOVERY
PEER_DETECTION
) )
func (n NATSMethod) String() string { func (n NATSMethod) String() string {
@@ -34,7 +33,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, PEER_DISCOVERY, PEER_DETECTION} { for _, v := range [...]NATSMethod{REMOVE_EXECUTION, CREATE_EXECTUTION, DISCOVERY, WORKFLOW_EVENT, PEER_DISCOVERY} {
if strings.Contains(strings.ToLower(v.String()), strings.ToLower(name)) { if strings.Contains(strings.ToLower(v.String()), strings.ToLower(name)) {
return v return v
} }
@@ -81,7 +80,7 @@ func (s *natsCaller) ListenNats(execs map[NATSMethod]func(map[string]string)) {
} }
// SetNATSPub sets a message to the NATS server // SetNATSPub sets a message to the NATS server
func (o *natsCaller) SetNATSPub(dataName string, method NATSMethod, data interface{}) string { func (o *natsCaller) SetNATSPub(method NATSMethod, data interface{}) string {
if config.GetConfig().NATSUrl == "" { if config.GetConfig().NATSUrl == "" {
return " -> NATS_SERVER is not set" return " -> NATS_SERVER is not set"
} }