From b99091f08115fb013f7e5f6465accd3c73c6ce2f Mon Sep 17 00:00:00 2001
From: Yannick Huber <huber@belwue.de>
Date: Thu, 21 Nov 2024 08:51:01 +0100
Subject: [PATCH] bugfix: goflow segment not registered

---
 segments/input/goflow/goflow.go | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/segments/input/goflow/goflow.go b/segments/input/goflow/goflow.go
index d1799c6..2b1944b 100644
--- a/segments/input/goflow/goflow.go
+++ b/segments/input/goflow/goflow.go
@@ -146,6 +146,11 @@ func (d *myProtobufDriver) Format(data interface{}) ([]byte, []byte, error) {
 func (d *myProtobufDriver) Prepare() error             { return nil }
 func (d *myProtobufDriver) Init(context.Context) error { return nil }
 
+func init() {
+	segment := &Goflow{}
+	segments.RegisterSegment("goflow", segment)
+}
+
 func (segment *Goflow) startGoFlow(transport transport.TransportInterface) {
 	formatter := &myProtobufDriver{}