Versions in this module Expand all Collapse all v1 v1.0.0 Sep 20, 2019 Changes in this version + func DecodeCopyToTuples(colBuf *bytes.Buffer, out utils.Writer, pgColumns map[int]*config.PgColumn, ...) error + type BulkUpload struct + func New(chConn chutils.CHConnector, gzipBufSize int, comprLevel config.GzipComprLevel) *BulkUpload + func (c *BulkUpload) BulkUpload(tableName config.ChTableName, columns []string) error + func (c *BulkUpload) Finish() error + func (c *BulkUpload) Init(buf buffer.BufferAt) error + func (c *BulkUpload) Write(p []byte) (int, error) + func (c *BulkUpload) WriteByte(p byte) error + type BulkUploader interface + BulkUpload func(name config.ChTableName, columns []string) error + Finish func() error + Init func(buffer.BufferAt) error