ckwriter

Documentation

Index

• Constants
• func ExecSQL(conn clickhouse.Conn, query string) error
• func InitTable(addr, user, password, timeZone string, t *ckdb.Table) error
• func IsNil(i interface{}) bool
• type CKItem
• type CKWriter
  • func NewCKWriter(addrs []string, user, password, counterName, timeZone string, ...) (*CKWriter, error)
  • func (w *CKWriter) Close()
  • func (w *CKWriter) Put(items ...interface{})
  • func (w *CKWriter) ResetConnection(connID int) error
  • func (w *CKWriter) Run()
  • func (w *CKWriter) Write(queueID int, items []CKItem)
• type Counter
  • func (i *Counter) GetCounter() interface{}

Constants

const (
	FLUSH_TIMEOUT  = 10 * time.Second
	SQL_LOG_LENGTH = 256
)

Functions

func ExecSQL

func ExecSQL(conn clickhouse.Conn, query string) error

func InitTable

func InitTable(addr, user, password, timeZone string, t *ckdb.Table) error

func IsNil

func IsNil(i interface{}) bool

Types

type CKItem

type CKItem interface {
	WriteBlock(block *ckdb.Block)
	Release()
}

type CKWriter

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

func NewCKWriter

func NewCKWriter(addrs []string, user, password, counterName, timeZone string, table *ckdb.Table, queueCount, queueSize, batchSize, flushTimeout int) (*CKWriter, error)

func (*CKWriter) Close

func (w *CKWriter) Close()

func (*CKWriter) Put

func (w *CKWriter) Put(items ...interface{})

func (*CKWriter) ResetConnection

func (w *CKWriter) ResetConnection(connID int) error

func (*CKWriter) Run

func (w *CKWriter) Run()

func (*CKWriter) Write

func (w *CKWriter) Write(queueID int, items []CKItem)

type Counter

type Counter struct {
	WriteSuccessCount int64 `statsd:"write-success-count"`
	WriteFailedCount  int64 `statsd:"write-failed-count"`
	RetryCount        int64 `statsd:"retry-count"`
	RetryFailedCount  int64 `statsd:"retry-failed-count"`
	utils.Closable
}

func (*Counter) GetCounter

func (i *Counter) GetCounter() interface{}