Merge pull request BelWue#5 from ynHuber/bugfix_goflowtest_failing

bugfix: goflow segment not registered
Mynacol · Nov 22, 2024 · 6bc8c70 · 6bc8c70
2 parents dce2042 + b99091f
commit 6bc8c70
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/segments/input/goflow/goflow.go b/segments/input/goflow/goflow.go
@@ -158,6 +158,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{}
 	var pipes []utils.FlowPipe