clickhouse

Documentation

Index

• type Clickhouse
  • func NewClickhouse(config *Config) (*Clickhouse, error)
  • func (clickhouse *Clickhouse) Check(source string, fields map[string]string)
  • func (clickhouse *Clickhouse) IsDataPresent(startDate string, endDate string, source string) (bool, error)
  • func (clickhouse *Clickhouse) Query(query string) (*sqlx.Rows, error)
  • func (clickhouse *Clickhouse) SaveData(source string, fields []string)
• type Config
  • func NewClickhouseConfig() (*Config, error)
  • func (config Config) Validate() error

Types

type Clickhouse

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

func NewClickhouse

func NewClickhouse(config *Config) (*Clickhouse, error)

func (*Clickhouse) Check

func (clickhouse *Clickhouse) Check(source string, fields map[string]string)

func (*Clickhouse) IsDataPresent

func (clickhouse *Clickhouse) IsDataPresent(startDate string, endDate string, source string) (bool, error)

func (*Clickhouse) Query

func (clickhouse *Clickhouse) Query(query string) (*sqlx.Rows, error)

func (*Clickhouse) SaveData

func (clickhouse *Clickhouse) SaveData(source string, fields []string)

type Config

type Config struct {
	Host        string `mapstructure:"host"`
	Port        int    `mapstructure:"port"`
	User        string `mapstructure:"user"`
	Password    string `mapstructure:"password"`
	VisitsTable string `mapstructure:"visitsTable"`
	HitsTable   string `mapstructure:"hitsTable"`
	Database    string `mapstructure:"database"`
}

func NewClickhouseConfig

func NewClickhouseConfig() (*Config, error)

func (Config) Validate

func (config Config) Validate() error