clickhousegw

Documentation

Index

• type ClickHouseGateway
  • func New(cfg *ClickhouseConfig) (*ClickHouseGateway, error)
  • func (c *ClickHouseGateway) Close()
  • func (c *ClickHouseGateway) DescribeDict(dictName string) ([]string, error)
  • func (c *ClickHouseGateway) DescribeTable(tableName string) ([]string, error)
  • func (c *ClickHouseGateway) GetColumnValues(columnName string) ([]string, error)
  • func (c *ClickHouseGateway) GetDatabaseName() string
  • func (c *ClickHouseGateway) GetDictValues(dictName string, attr string) ([]string, error)
  • func (c *ClickHouseGateway) InsertFlows(flows []*flow.Flow) error
  • func (c *ClickHouseGateway) Query(q string) (*sql.Rows, error)
• type ClickhouseConfig

Types

type ClickHouseGateway

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

ClickHouseGateway is a wrapper for Clickhouse

func New

func New(cfg *ClickhouseConfig) (*ClickHouseGateway, error)

New instantiates a new ClickHouseGateway

func (*ClickHouseGateway) Close

func (c *ClickHouseGateway) Close()

Close closes the database handler

func (*ClickHouseGateway) DescribeDict

func (c *ClickHouseGateway) DescribeDict(dictName string) ([]string, error)

DescribeDict gets the names of all fields in a dictionary

func (*ClickHouseGateway) DescribeTable

func (c *ClickHouseGateway) DescribeTable(tableName string) ([]string, error)

DescribeTable gets the names of all fields of a table

func (*ClickHouseGateway) GetColumnValues

func (c *ClickHouseGateway) GetColumnValues(columnName string) ([]string, error)

GetColumnValues gets all unique values of a column

func (*ClickHouseGateway) GetDatabaseName

func (c *ClickHouseGateway) GetDatabaseName() string

GetDatabaseName gets the databases name

func (*ClickHouseGateway) GetDictValues

func (c *ClickHouseGateway) GetDictValues(dictName string, attr string) ([]string, error)

GetDictValues gets all values of a certain dicts attribute

func (*ClickHouseGateway) InsertFlows

func (c *ClickHouseGateway) InsertFlows(flows []*flow.Flow) error

InsertFlows inserts flows into clickhouse

func (*ClickHouseGateway) Query

func (c *ClickHouseGateway) Query(q string) (*sql.Rows, error)

Query executs an SQL query

type ClickhouseConfig

type ClickhouseConfig struct {
	Host     string `yaml:"host"`
	Address  string `yaml:"address"`
	User     string `yaml:"user"`
	Password string `yaml:"password"`
	Database string `yaml:"database"`
}

ClickhouseConfig represents a clickhouse client config