cx

type Batch ¶

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

Batch holds information for sending rows batch

func NewBatch(rows []Vector) *Batch

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

type Buffer ¶

type Buffer interface {
	Write(Vector)
	Read() []Vector
	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 Clickhouse ¶

type Clickhouse interface {
	Insert(context.Context, View, []Vector) (uint64, error)
	Close() error
}

type Logger ¶

type Logger interface {
	Log(message interface{})
	Logf(format string, v ...interface{})
}

func NewDefaultLogger() Logger

type Vector ¶

type Vector []interface{}

func (v Vector) Encode() ([]byte, error)

type VectorDecoded ¶

type VectorDecoded string

func (d VectorDecoded) Decode() (Vector, error)

type Vectorable ¶

type Vectorable interface {
	Row() Vector
}

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

type View ¶

type View struct {
	Name    string
	Columns []string
}

func NewView(name string, columns []string) View