buffer

type Batch ¶ added in v0.0.2

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

Batch holds information for sending rows batch

func NewBatch(rows []RowSlice) *Batch

func (b *Batch) Rows() []RowSlice

type Buffer ¶

type Buffer interface {
	Write(RowSlice)
	Read() []RowSlice
	Len() int
	Flush()
}

Buffer it is the interface for creating a data buffer (temporary storage). It is enough to implement this interface so that you can use your own temporary storage

type Inline ¶ added in v0.0.2

type Inline interface {
	Row() RowSlice
}

Inline interface is an assistant in the correct formation of the order of fields in the data before sending it to Clickhouse

type RowDecoded ¶ added in v0.0.2

type RowDecoded string

func (rd RowDecoded) Decode() (RowSlice, error)

type RowSlice ¶ added in v0.0.2

type RowSlice []interface{}

func (rw RowSlice) Encode() ([]byte, error)