ClusterCockpit/cc-metric-collector
1
0
Fork 0
mirror of https://github.com/ClusterCockpit/cc-metric-collector.git synced 2025-04-06 13:35:55 +02:00
Code Issues Packages Projects Releases Wiki Activity

Define default port for NATS

Browse Source
This commit is contained in:
Thomas Roehl 2024-12-19 20:38:31 +01:00
parent c6741ba209
commit 6139932d33
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
sinks/natsSink.go
View File

@ -103,7 +103,6 @@ func (s *NatsSink) Flush() error {
if len(buf) == 0 { if len(buf) == 0 {
return nil return nil
} }
if err := s.client.Publish(s.config.Subject, buf); err != nil { if err := s.client.Publish(s.config.Subject, buf); err != nil {
cclog.ComponentError(s.name, "Flush:", err.Error()) cclog.ComponentError(s.name, "Flush:", err.Error())
return err return err
@ -120,6 +119,7 @@ func NewNatsSink(name string, config json.RawMessage) (Sink, error) {
s := new(NatsSink) s := new(NatsSink)
s.name = fmt.Sprintf("NatsSink(%s)", name) s.name = fmt.Sprintf("NatsSink(%s)", name)
s.flushDelay = 10 * time.Second s.flushDelay = 10 * time.Second
s.config.Port = "4222"
if len(config) > 0 { if len(config) > 0 {
d := json.NewDecoder(bytes.NewReader(config)) d := json.NewDecoder(bytes.NewReader(config))
d.DisallowUnknownFields() d.DisallowUnknownFields()