From 82e9477b1877c44c9970de287f55ebc60fcb61f3 Mon Sep 17 00:00:00 2001 From: postmannen Date: Wed, 25 Aug 2021 16:17:33 +0200 Subject: [PATCH] commented out some logging --- message_and_subject.go | 4 +++- ringbuffer.go | 10 +++++----- 2 files changed, 8 insertions(+), 6 deletions(-) diff --git a/message_and_subject.go b/message_and_subject.go index cf96fad..3fd206f 100644 --- a/message_and_subject.go +++ b/message_and_subject.go @@ -12,8 +12,10 @@ import ( // --- Message type Message struct { - // The node to send the message to + // The node to send the message to. ToNode Node `json:"toNode" yaml:"toNode"` + // ToNodes to specify several hosts to send message to. + ToNodes []Node `json:"toNodes,omitempty" yaml:"toNodes,omitempty"` // The Unique ID of the message ID int `json:"id" yaml:"id"` // The actual data in the message diff --git a/ringbuffer.go b/ringbuffer.go index 339a060..7fb88a2 100644 --- a/ringbuffer.go +++ b/ringbuffer.go @@ -289,11 +289,11 @@ func (r *ringBuffer) processBufferMessages(samValueBucket string, outCh chan sam r.permStore <- fmt.Sprintf("%v : %+v\n", time.Now().UTC(), v) - // REMOVE: Dump the whole KV store - err := r.printBucketContent(samValueBucket) - if err != nil { - log.Printf("* Error: dump of db failed: %v\n", err) - } + // TODO: REMOVE: Dump the whole KV store + // err := r.printBucketContent(samValueBucket) + // if err != nil { + // log.Printf("* Error: dump of db failed: %v\n", err) + // } }(v) }