Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

helper

package

Go to main page

Versions in this module

v1

v1.17.4

Sep 28, 2023

v1.17.3

Sep 7, 2023

v1.17.2

May 23, 2023

v1.17.1

May 8, 2023

v1.16.3

Apr 29, 2023

v1.16.2

Apr 20, 2023

Changes in this version

+ func AssertNextByteEqual(z *bytepool.ZReader, expect byte) error

+ func BlockToFrame(blockStream <-chan *data.Block) (<-chan [][]string, []*column.CHColumn, func([][]string), bool)

+ func DiscardUntilByteEscaped(z *bytepool.ZReader, stop byte) error

+ func FlushZReader(z *bytepool.ZReader)

+ func ReadCHElemTillStop(w Writer, z *bytepool.ZReader, col column.CHColumnData, stop byte) error

+ func ReadColumnTextsCont(fb *bytepool.FrameBuffer, numRows int, cols []*column.CHColumn, ...) (int, error)

+ func ReadFirstColumnTexts(fb *bytepool.FrameBuffer, numRows int, cols []*column.CHColumn, ...) (int, error)

+ func ReadNextNonSpaceByte(z *bytepool.ZReader) (byte, error)

+ func ReadNextNonSpaceExceptNewLineByte(z *bytepool.ZReader) (byte, error)

+ func ReadRow(fb *bytepool.FrameBuffer, cols []*column.CHColumn, e ElemReader) error

+ func ReadStringUntilByte(w Writer, z *bytepool.ZReader, b byte) (int, error)

+ func TableToBlockStream(ctx context.Context, sample *data.Block, blockSize int, tReader TableReader) (blockStream <-chan *data.Block, yield func() (int, error))

+ func WriteCHElemString(w io.Writer, s string, col *column.CHColumn) error

+ func WriteFirstFrame(frame [][]string, cols []*column.CHColumn, rWriter RowWriter) (int, error)

+ func WriteFrameCont(frame [][]string, cols []*column.CHColumn, rWriter RowWriter) (int, error)

+ func WriteTableFromBlockStream(blockStream <-chan *data.Block, tWriter TableWriter) (int, error)

+ func YieldTableStream(eg *errgroup.Group, colTextsStreamer *ColumnTextsStreamer, ...) func() (int, error)

+ type ColumnTextsPool struct

+ func NewColumnTextsPool(numCols, numRows int) *ColumnTextsPool

+ func (c *ColumnTextsPool) NewColumnTextsResult(fb *bytepool.FrameBuffer) *ColumnTextsResult

+ type ColumnTextsResult struct

+ func (c *ColumnTextsResult) Close()

+ func (c *ColumnTextsResult) Get() [][]string

+ type ColumnTextsStreamer struct

+ func NewColumnTextsStreamer(sample *data.Block, blockSize int, tReader TableReader) *ColumnTextsStreamer

+ func (c *ColumnTextsStreamer) Finish() (int, error)

+ func (c *ColumnTextsStreamer) Start(ctx context.Context) <-chan *ColumnTextsResult

+ type ColumnTextsToBlock struct

+ func NewColumnTextsToBlock(ctStream <-chan *ColumnTextsResult, sample *data.Block) *ColumnTextsToBlock

+ func (a *ColumnTextsToBlock) Error() error

+ func (a *ColumnTextsToBlock) Finish() (rowsProcessed int, err error)

+ func (a *ColumnTextsToBlock) Start(ctx context.Context) <-chan *data.Block

+ type ElemReader interface

+ ReadElem func(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)

+ var RecycleColumnTextsNoOp RecycleColumnTexts = func(columnTexts [][]string) { ... }

+ type RowReader interface

+ ReadFirstRow func(fb *bytepool.FrameBuffer, cols []*column.CHColumn) error

+ ReadRowCont func(fb *bytepool.FrameBuffer, cols []*column.CHColumn) error

+ type RowWriter interface

+ WriteFirstRow func(record []string, cols []*column.CHColumn) error

+ WriteRowCont func(record []string, cols []*column.CHColumn) error

+ type TableReader interface

+ ReadColumnTextsCont func(fb *bytepool.FrameBuffer, numRows int, cols []*column.CHColumn) (int, error)

+ ReadFirstColumnTexts func(fb *bytepool.FrameBuffer, numRows int, cols []*column.CHColumn) (int, error)

+ type TableWriter interface

+ Flush func() error

+ WriteFirstFrame func(frame [][]string, cols []*column.CHColumn) (int, error)

+ WriteFrameCont func(frame [][]string, cols []*column.CHColumn) (int, error)

+ type Writer interface