feat: Updated pumps/logzio.go

TykTechnologies · Jan 29, 2024 · 7ea3f18 · 7ea3f18
1 parent 954d546
commit 7ea3f18
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/pumps/logzio.go b/pumps/logzio.go
@@ -159,7 +159,10 @@ func (p *LogzioPump) WriteData(ctx context.Context, data []interface{}) error {
 			return fmt.Errorf("failed to marshal decoded data: %s", err)
 		}
 
-		p.sender.Send(event)
+		err = p.sender.Send(event)
+if err != nil {
+    return fmt.Errorf("failed to send event: %s", err)
+}
 	}
 	p.log.Info("Purged ", len(data), " records...")