NewLogPipe creates a LogPipe server.

DefaultLogSize is the maximum size bundle we will accept.

ErrFailedProcessing indicates a failure in processing that can be retried.

Config is the configuration of the server.

FileMeta is a simple struct for passing ip info with filenames..

LogPipe pipes data from protobuf-generated logs (see log/client.go for the client) to elasticsearch in a structured fashion.