Suppress backlog (optionally)

See PR gliderlabs#201. Set BACKLOG=false to disable default behaviour of sending backlogs.
olivergrahl · Nov 16, 2016 · d7a42d8 · d7a42d8
1 parent 647c2c7
commit d7a42d8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/router/pump.go b/router/pump.go
@@ -140,7 +140,7 @@ func (p *LogsPump) Run() error {
 		debug("pump.Run() event:", normalID(event.ID), event.Status)
 		switch event.Status {
 		case "start", "restart":
-			go p.pumpLogs(event, true, inactivityTimeout)
+			go p.pumpLogs(event, os.Getenv("BACKLOG") != "false", inactivityTimeout)
 		case "rename":
 			go p.rename(event)
 		case "die":