stream

Documentation

Index

• func Parse(bc *handshake.BufferedConn, callback func(rows []storage.MetricRow) error, ...) error

Functions

func Parse

func Parse(bc *handshake.BufferedConn, callback func(rows []storage.MetricRow) error, isReadOnly func() bool) error

Parse parses data sent from vminsert to bc and calls callback for parsed rows. Optional function isReadOnly must return true if the storage cannot accept new data. In this case the data read from bc isn't accepted and the readonly status is sent back bc.

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

callback shouldn't hold block after returning.