clickhouse

Documentation

Index

• type BufferConfig
• type ChConn
  • func New(config *Config) (ChConn, error)
• type Config
• type Stommer
  • func NewStommer(o interface{}, omitted ...string) (*Stommer, error)
  • func (s *Stommer) WithPrefix(prefix string) *Stommer

Types

type BufferConfig

type BufferConfig struct {
	DequeueDelay      time.Duration `envconfig:"default=1s"`
	BufferWaitRetries time.Duration `envconfig:"default=100ms"`
	BufferSize        uint64        `envconfig:"default=30"`
	WithBuffer        bool          `envconfig:"default=true"`
	Ratelimit         int           `envconfig:"default=1024"`
	DequeueTimeout    time.Duration `envconfig:"default=3m"`
}

type ChConn

type ChConn interface {
	Master() *sql.DB
	PingMaster() bool
}

func New

func New(config *Config) (ChConn, error)

type Config

type Config struct {
	DSN                string
	DialTimeout        time.Duration `envconfig:"default=1s"`
	MaxOpenConns       int           `envconfig:"default=10"`
	MaxIdleConns       int           `envconfig:"default=5"`
	ConnMaxLifetime    time.Duration `envconfig:"default=60m"`
	MaxExecutionTime   int           `envconfig:"default=60"`
	HealthCheckTimeout time.Duration `envconfig:"default=1000ms"`
	BufferConfig       BufferConfig
}

type Stommer

type Stommer struct {
	Mapper  map[string]interface{}
	Columns []string
	Values  []interface{}
}

func NewStommer

func NewStommer(o interface{}, omitted ...string) (*Stommer, error)

func (*Stommer) WithPrefix

func (s *Stommer) WithPrefix(prefix string) *Stommer