in pkg/output/rally/rally.go [79:93]
func (r *Output) Write(b []byte) (int, error) {
e := &entry{
Message: string(b),
}
jsonBytes, err := json.Marshal(e)
if err != nil {
return 0, err
}
n, err := r.pWriteCloser.Write(jsonBytes)
if err != nil {
return n, err
}
k, err := r.pWriteCloser.Write([]byte("\n"))
return n + k, err
}