stream

Documentation

Index

• func Parse(r io.Reader, isGzipped bool, callback func(rows []statsd.Row) error) error

Functions

func Parse

func Parse(r io.Reader, isGzipped bool, callback func(rows []statsd.Row) error) error

Parse parses Statsd lines from r and calls callback for the parsed rows.

The callback can be called concurrently multiple times for streamed data from r.

callback shouldn't hold rows after returning.