clickhouse

Documentation

Index

• type Client
  • func NewClient(address, username, password, database, dialTimeout, connMaxLifetime string, ...) (*Client, error)
  • func (c *Client) BufferAdd(row Row)
  • func (c *Client) BufferLen() int
  • func (c *Client) BufferWrite() error
  • func (c *Client) Close() error
• type Row

Types

type Client

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

Client can be used to write data to a ClickHouse instance. The client can be created via the NewClient function.

func NewClient

func NewClient(address, username, password, database, dialTimeout, connMaxLifetime string, maxIdleConns, maxOpenConns int, asyncInsert, waitForAsyncInsert bool) (*Client, error)

NewClient returns a new client for ClickHouse. The client can then be used to write data to ClickHouse via the "Write" method.

func (*Client) BufferAdd

func (c *Client) BufferAdd(row Row)

BufferAdd adds a new row to the Clickhouse buffer. This doesn't write the added row. To write the rows in the buffer the `write` method must be called.

func (*Client) BufferLen

func (c *Client) BufferLen() int

BufferLen returns the number of items in the buffer.

func (*Client) BufferWrite

func (c *Client) BufferWrite() error

BufferWrite writes a list of rows from the buffer to the configured ClickHouse instance.

func (*Client) Close

func (c *Client) Close() error

Close can be used to close the underlying sql client for ClickHouse.

type Row

type Row struct {
	Timestamp    time.Time
	Cluster      string
	Namespace    string
	App          string
	Pod          string
	Container    string
	Host         string
	FieldsString map[string]string
	FieldsNumber map[string]float64
	Log          string
}

Row is the structure of a single row in ClickHouse.