helper

type ColumnTextsPool struct {
	// contains filtered or unexported fields
}

type ColumnTextsResult struct {
	// contains filtered or unexported fields
}

type ColumnTextsStreamer struct {
	// contains filtered or unexported fields
}

type ColumnTextsToBlock struct {
	// contains filtered or unexported fields
}

type ElemReader interface {
	ReadElem(fb *bytepool.FrameBuffer, cols []*column.CHColumn, idx int) error
}

type ReadColumnTexts func(fb *bytepool.FrameBuffer, rows int, cols []*column.CHColumn) (int, error)

type RecycleColumnTexts func(columnTexts [][]string)

type RowReader interface {
	ReadFirstRow(fb *bytepool.FrameBuffer, cols []*column.CHColumn) error
	ReadRowCont(fb *bytepool.FrameBuffer, cols []*column.CHColumn) error
}

type RowWriter interface {
	WriteFirstRow(record []string, cols []*column.CHColumn) error
	WriteRowCont(record []string, cols []*column.CHColumn) error
}

type TableReader interface {
	ReadFirstColumnTexts(fb *bytepool.FrameBuffer, numRows int, cols []*column.CHColumn) (int, error)
	ReadColumnTextsCont(fb *bytepool.FrameBuffer, numRows int, cols []*column.CHColumn) (int, error)
}

type TableWriter interface {
	// WriteFirstFrame writes the first frame generated from the first block with data from server.
	// meant for writing Headers if any (eg. JSON)
	// return number of rows written and error if any.
	WriteFirstFrame(frame [][]string, cols []*column.CHColumn) (int, error)
	// WriteFrameCont is same as WriteFirstFrame but not for first row
	WriteFrameCont(frame [][]string, cols []*column.CHColumn) (int, error)
	// Flush indicates all blocks are read and caller should write any last data and do clean up
	Flush() error
}

type Writer interface {
	io.Writer
	io.StringWriter
	io.ByteWriter
}