Documentation ¶
Index ¶
- func ConnectClickHouse(url string) (*sql.DB, error)
- func PrepareConnection(input ClickHouseInput) (string, *sql.DB, error)
- type ClickHouseExportProcess
- func (ch *ClickHouseExportProcess) CacheSet(set ipfixentities.Set)
- func (ch *ClickHouseExportProcess) GetCommitInterval() time.Duration
- func (ch *ClickHouseExportProcess) GetDsn() string
- func (ch *ClickHouseExportProcess) GetDsnMap() map[string]string
- func (ch *ClickHouseExportProcess) SetCommitInterval(commitInterval time.Duration)
- func (ch *ClickHouseExportProcess) Start()
- func (ch *ClickHouseExportProcess) Stop()
- func (ch *ClickHouseExportProcess) UpdateCH(input *ClickHouseExportProcess, dsn string, connect *sql.DB)
- type ClickHouseFlowRow
- type ClickHouseInput
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func PrepareConnection ¶ added in v1.8.0
func PrepareConnection(input ClickHouseInput) (string, *sql.DB, error)
Types ¶
type ClickHouseExportProcess ¶
type ClickHouseExportProcess struct {
// contains filtered or unexported fields
}
func NewClickHouseClient ¶
func NewClickHouseClient(input ClickHouseInput) (*ClickHouseExportProcess, error)
func (*ClickHouseExportProcess) CacheSet ¶
func (ch *ClickHouseExportProcess) CacheSet(set ipfixentities.Set)
func (*ClickHouseExportProcess) GetCommitInterval ¶ added in v1.8.0
func (ch *ClickHouseExportProcess) GetCommitInterval() time.Duration
func (*ClickHouseExportProcess) GetDsn ¶ added in v1.8.0
func (ch *ClickHouseExportProcess) GetDsn() string
func (*ClickHouseExportProcess) GetDsnMap ¶ added in v1.8.0
func (ch *ClickHouseExportProcess) GetDsnMap() map[string]string
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(input *ClickHouseExportProcess, dsn string, connect *sql.DB)
type ClickHouseFlowRow ¶
type ClickHouseFlowRow struct {
// contains filtered or unexported fields
}
Click to show internal directories.
Click to hide internal directories.