I've added an extra struct to capture status and error messages, and a goroutine to monitor a channel for those messages now.

https://github.com/mozilla-services/heka/blob/a52f49cc7c68c6725ff08ccf7f21d9088b34b47e/pipeline/logfile_input.go#L147