clickhouse

README

Clickhouse

A Clickhouse storage driver using https://github.com/ClickHouse/clickhouse-go.

Table of Contents

• Signatures
• Installation
• Examples
• Config
• Default Config

Signatures

func New(config ...Config) (*Storage, error)
func (s *Storage) Get(key string) ([]byte, error)
func (s *Storage) Set(key string, val []byte, exp time.Duration) error
func (s *Storage) Delete(key string) error
func (s *Storage) Reset() error
func (s *Storage) Close() error
func (s *Storage) Conn() *Session

Installation

Clickhouse is supported on the latest two versions of Go:

Install the clickhouse implementation:

go get github.com/gofiber/storage/clickhouse

Before running or testing this implementation, you must ensure a Clickhouse cluster is available. For local development, we recommend using the Clickhouse Docker image; it contains everything necessary for the client to operate correctly.

To start Clickhouse using Docker, issue the following:

docker run -d -p 9000:9000 --name some-clickhouse-server --ulimit nofile=262144:262144 clickhouse/clickhouse-server

After running this command you're ready to start using the storage and connecting to the database.

Examples

You can use the following options to create a clickhouse storage driver:

import "github.com/gofiber/storage/clickhouse"

// Initialize default config, to connect to localhost:9000 using the memory engine and with a clean table.
store, err := clickhouse.New(clickhouse.Config{
    Host: "localhost",
    Port: 9000,
    Clean: true,
})

// Initialize custom config to connect to a different host/port and use custom engine and with clean table.
store, err := clickhouse.New(clickhouse.Config{
    Host: "some-ip-address",
    Port: 9000,
    Engine: clickhouse.MergeTree,
    Clean: true,
})

// Initialize to connect with TLS enabled with your own tls.Config and with clean table.
tlsConfig := config := &tls.Config{...}

store, err := clickhouse.New(clickhouse.Config{
    Host: "some-ip-address",
    Port: 9000,
    Clean: true,
    TLSConfig: tlsConfig,
})

Config

// Config defines configuration options for Clickhouse connection.
type Config struct {
    // The host of the database. Ex: 127.0.0.1
    Host string
    // The port where the database is supposed to listen to. Ex: 9000
    Port int
    // The database that the connection should authenticate from
    Database string
    // The username to be used in the authentication
    Username string
    // The password to be used in the authentication
    Password string
    // The name of the table that will store the data
    Table string
    // The engine that should be used in the table
    Engine string
    // Should start a clean table, default false
    Clean bool
    // TLS configuration, default nil
    TLSConfig *tls.Config
    // Should the connection be in debug mode, default false
    Debug bool
    // The function to use with the debug config, default print function. It only works when debug is true
    Debugf func(format string, v ...any)
}

Default Config

var DefaultConfig = Config{
    Host:      "localhost",
    Port:      9000,
    Engine:    "Memory",
    Clean:     false,
}

Documentation

Index

• type ClickhouseEngine
• type Config
• type Storage
  • func New(configuration Config) (*Storage, error)
  • func (s *Storage) Close() error
  • func (s *Storage) Delete(key string) error
  • func (s *Storage) Get(key string) ([]byte, error)
  • func (s *Storage) Reset() error
  • func (s *Storage) Set(key string, value []byte, expiration time.Duration) error

Types

type ClickhouseEngine

type ClickhouseEngine string

const (
	Memory    ClickhouseEngine = "Memory"
	MergeTree ClickhouseEngine = "MergeTree"
	StripeLog ClickhouseEngine = "StripeLog"
	TinyLog   ClickhouseEngine = "TinyLog"
	Log       ClickhouseEngine = "Log"
)

type Config

type Config struct {
	// The host of the database. Ex: 127.0.0.1
	Host string
	// The port where the database is supposed to listen to. Ex: 9000
	Port int
	// The database that the connection should authenticate from
	Database string
	// The username to be used in the authentication
	Username string
	// The password to be used in the authentication
	Password string
	// The name of the table that will store the data
	Table string
	// The engine that should be used in the table
	Engine ClickhouseEngine
	// Should start a clean table, default false
	Clean bool
	// TLS configuration, default nil
	TLSConfig *tls.Config
	// Should the connection be in debug mode, default false
	Debug bool
	// The function to use with the debug config, default print function. It only works when debug is true
	Debugf func(format string, v ...any)
}

Config defines configuration options for Clickhouse connection.

type Storage

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

func New

func New(configuration Config) (*Storage, error)

New returns a new *Storage given a Config.

func (*Storage) Close

func (s *Storage) Close() error

func (*Storage) Delete

func (s *Storage) Delete(key string) error

func (*Storage) Get

func (s *Storage) Get(key string) ([]byte, error)

func (*Storage) Reset

func (s *Storage) Reset() error

func (*Storage) Set

func (s *Storage) Set(key string, value []byte, expiration time.Duration) error