clusternative

Documentation

Index

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

Functions

func ParseStream

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

ParseStream 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 thic 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.