cleanup error messages

This commit is contained in:
Joel Wetzell
2026-02-09 19:15:34 -06:00
parent 988437fccf
commit 6b178d1ae4
6 changed files with 9 additions and 9 deletions

View File

@@ -65,7 +65,7 @@ func init() {
portNum, ok := port.(float64) portNum, ok := port.(float64)
if !ok { if !ok {
return nil, errors.New("http.server port must be uint16") return nil, errors.New("http.server port must be a number")
} }
return &HTTPServer{Port: uint16(portNum), config: config, logger: CreateLogger(config)}, nil return &HTTPServer{Port: uint16(portNum), config: config, logger: CreateLogger(config)}, nil

View File

@@ -36,7 +36,7 @@ func init() {
brokerString, ok := broker.(string) brokerString, ok := broker.(string)
if !ok { if !ok {
return nil, errors.New("mqtt.client broker must be string") return nil, errors.New("mqtt.client broker must be a string")
} }
topic, ok := params["topic"] topic, ok := params["topic"]
@@ -48,7 +48,7 @@ func init() {
topicString, ok := topic.(string) topicString, ok := topic.(string)
if !ok { if !ok {
return nil, errors.New("mqtt.client topic must be string") return nil, errors.New("mqtt.client topic must be a string")
} }
clientId, ok := params["clientId"] clientId, ok := params["clientId"]
@@ -60,7 +60,7 @@ func init() {
clientIdString, ok := clientId.(string) clientIdString, ok := clientId.(string)
if !ok { if !ok {
return nil, errors.New("mqtt.client clientId must be string") return nil, errors.New("mqtt.client clientId must be a string")
} }
return &MQTTClient{config: config, Broker: brokerString, Topic: topicString, ClientID: clientIdString, logger: CreateLogger(config)}, nil return &MQTTClient{config: config, Broker: brokerString, Topic: topicString, ClientID: clientIdString, logger: CreateLogger(config)}, nil

View File

@@ -36,7 +36,7 @@ func init() {
urlString, ok := url.(string) urlString, ok := url.(string)
if !ok { if !ok {
return nil, errors.New("nats.client url must be string") return nil, errors.New("nats.client url must be a string")
} }
subject, ok := params["subject"] subject, ok := params["subject"]
@@ -48,7 +48,7 @@ func init() {
subjectString, ok := subject.(string) subjectString, ok := subject.(string)
if !ok { if !ok {
return nil, errors.New("nats.client subject must be string") return nil, errors.New("nats.client subject must be a string")
} }
return &NATSClient{config: config, URL: urlString, Subject: subjectString, logger: CreateLogger(config)}, nil return &NATSClient{config: config, URL: urlString, Subject: subjectString, logger: CreateLogger(config)}, nil

View File

@@ -38,7 +38,7 @@ func init() {
hostString, ok := host.(string) hostString, ok := host.(string)
if !ok { if !ok {
return nil, errors.New("net.tcp.client host must be string") return nil, errors.New("net.tcp.client host must be a string")
} }
port, ok := params["port"] port, ok := params["port"]

View File

@@ -34,7 +34,7 @@ func init() {
durationNum, ok := duration.(float64) durationNum, ok := duration.(float64)
if !ok { if !ok {
return nil, errors.New("time.interval duration must be number") return nil, errors.New("time.interval duration must be a number")
} }
return &TimeInterval{Duration: uint32(durationNum), config: config, logger: CreateLogger(config)}, nil return &TimeInterval{Duration: uint32(durationNum), config: config, logger: CreateLogger(config)}, nil
}, },

View File

@@ -36,7 +36,7 @@ func init() {
durationNum, ok := duration.(float64) durationNum, ok := duration.(float64)
if !ok { if !ok {
return nil, errors.New("time.sleep duration must be number") return nil, errors.New("time.sleep duration must be a number")
} }
return &MetaDelay{config: config, Duration: time.Millisecond * time.Duration(durationNum)}, nil return &MetaDelay{config: config, Duration: time.Millisecond * time.Duration(durationNum)}, nil