clickhouseclient

package
v1.15.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 25, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ProtocolUnknown = -1
)

Variables

View Source
var PrepareClickHouseConnection = prepareConnection

PrepareClickHouseConnection is used for unit testing

Functions

func ConnectClickHouse added in v1.8.0

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

Types

type ClickHouseConfig added in v1.13.0

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 added in v1.9.0

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

func (*ClickHouseExportProcess) GetClickHouseConfig added in v1.13.0

func (ch *ClickHouseExportProcess) GetClickHouseConfig() ClickHouseConfig

func (*ClickHouseExportProcess) GetCommitInterval added in v1.8.0

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

func (*ClickHouseExportProcess) SetCommitInterval added in v1.8.0

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

func (*ClickHouseExportProcess) Start

func (ch *ClickHouseExportProcess) Start()

func (*ClickHouseExportProcess) Stop

func (ch *ClickHouseExportProcess) Stop()

func (*ClickHouseExportProcess) UpdateCH added in v1.8.0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL