clickhouseclient

Documentation

Index

• Constants
• Variables
• func ConnectClickHouse(config *ClickHouseConfig) (*sql.DB, error)
• type ClickHouseConfig
• type ClickHouseExportProcess
  • func NewClickHouseClient(config ClickHouseConfig, clusterUUID string) (*ClickHouseExportProcess, error)
  • func (ch *ClickHouseExportProcess) CacheRecord(record ipfixentities.Record)
  • func (ch *ClickHouseExportProcess) GetClickHouseConfig() ClickHouseConfig
  • func (ch *ClickHouseExportProcess) GetCommitInterval() time.Duration
  • func (ch *ClickHouseExportProcess) SetCommitInterval(commitInterval time.Duration)
  • func (ch *ClickHouseExportProcess) Start()
  • func (ch *ClickHouseExportProcess) Stop()
  • func (ch *ClickHouseExportProcess) UpdateCH(config ClickHouseConfig, connect *sql.DB)

Constants

const (
	ProtocolUnknown = -1
)

Variables

var PrepareClickHouseConnection = prepareConnection

PrepareClickHouseConnection is used for unit testing

Functions

func ConnectClickHouse

func ConnectClickHouse(config *ClickHouseConfig) (*sql.DB, error)

Types

type ClickHouseConfig

type ClickHouseConfig struct {
	Username           string
	Password           string
	Database           string
	DatabaseURL        string
	Debug              bool
	Compress           *bool
	CommitInterval     time.Duration
	CACert             bool
	InsecureSkipVerify bool
	Certificate        []byte
}

type ClickHouseExportProcess

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

func NewClickHouseClient

func NewClickHouseClient(config ClickHouseConfig, clusterUUID string) (*ClickHouseExportProcess, error)

func (*ClickHouseExportProcess) CacheRecord

func (ch *ClickHouseExportProcess) CacheRecord(record ipfixentities.Record)

func (*ClickHouseExportProcess) GetClickHouseConfig

func (ch *ClickHouseExportProcess) GetClickHouseConfig() ClickHouseConfig

func (*ClickHouseExportProcess) GetCommitInterval

func (ch *ClickHouseExportProcess) GetCommitInterval() time.Duration

func (*ClickHouseExportProcess) SetCommitInterval

func (ch *ClickHouseExportProcess) SetCommitInterval(commitInterval time.Duration)

func (*ClickHouseExportProcess) Start

func (ch *ClickHouseExportProcess) Start()

func (*ClickHouseExportProcess) Stop

func (ch *ClickHouseExportProcess) Stop()

func (*ClickHouseExportProcess) UpdateCH

func (ch *ClickHouseExportProcess) UpdateCH(config ClickHouseConfig, connect *sql.DB)