clickhouse

Documentation

Index

• Variables
• type Builder
  • func NewBuilder() *Builder
  • func (b *Builder) Build() (*ClickHouse, error)
  • func (b *Builder) Config(config *Config) *Builder
  • func (b *Builder) Logger(logger Logger) *Builder
• type ClickHouse
  • func (ch *ClickHouse) Select(ctx context.Context, result any, query string, queryArgs map[string]any) error
  • func (ch *ClickHouse) Start(ctx context.Context) error
  • func (ch *ClickHouse) Stop(ctx context.Context) error
• type Config
• type Logger
• type Repository

Variables

var (
	ErrClickHouseConfigIsRequired = errors.NewError("SYS", "ClickHouse config is required")
	ErrLoggerIsRequired           = errors.NewError("SYS", "Logger is required")
)

Types

type Builder

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

func NewBuilder

func NewBuilder() *Builder

func (*Builder) Build

func (b *Builder) Build() (*ClickHouse, error)

func (*Builder) Config

func (b *Builder) Config(config *Config) *Builder

func (*Builder) Logger

func (b *Builder) Logger(logger Logger) *Builder

type ClickHouse

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

func (*ClickHouse) Select

func (ch *ClickHouse) Select(ctx context.Context, result any, query string, queryArgs map[string]any) error

func (*ClickHouse) Start

func (ch *ClickHouse) Start(ctx context.Context) error

func (*ClickHouse) Stop

func (ch *ClickHouse) Stop(ctx context.Context) error

type Config

type Config struct {
	URL          string
	Database     string
	Username     string
	Password     string
	MaxOpenConns int
	MaxIdleConns int
}

type Logger

type Logger interface {
	LogError(ctx context.Context, errs ...error)
	LogInfo(ctx context.Context, messages ...string)
}

type Repository

type Repository interface {
	Select(ctx context.Context, result any, query string, queryArgs map[string]any) error
}