karaolidis/telegraf-clickhouse-plugin
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Remove useless type

Browse Source 
Signed-off-by: Nikolaos Karaolidis <nick@karaolidis.com>
This commit is contained in:
Nick Karaolidis
2023-06-29 16:42:38 +03:00
parent e1160c0bef
commit 7c79958ae5
1 changed files with 2 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
plugins/outputs/clickhouse/clickhouse.go
View File

@@ -95,7 +95,7 @@ func (ch *ClickHouse) Init() error {
ch.metricQueue = make([]telegraf.Metric, 0, ch.QueueSize) ch.metricQueue = make([]telegraf.Metric, 0, ch.QueueSize)
ch.metricTrigger = make(chan struct{}, 1) ch.metricTrigger = make(chan struct{}, 1)
go ch.metricWriter(ch.FlushInterval) go ch.backgroundWriter(ch.FlushInterval)
return nil return nil
} }
@@ -174,11 +174,6 @@ func (ch *ClickHouse) valueToDatatype(value interface{}) string {
return datatype return datatype
} }
type NullUint64 struct {
Uint64 uint64
Valid bool
}
func (ch *ClickHouse) generateCreateTable(tablename string, columns *orderedmap.OrderedMap[string, string]) string { func (ch *ClickHouse) generateCreateTable(tablename string, columns *orderedmap.OrderedMap[string, string]) string {
columnDefs := make([]string, 0, columns.Len()) columnDefs := make([]string, 0, columns.Len())
@@ -460,7 +455,7 @@ func (ch *ClickHouse) Write(metrics []telegraf.Metric) error {
return nil return nil
} }
func (ch *ClickHouse) metricWriter(delay time.Duration) { func (ch *ClickHouse) backgroundWriter(delay time.Duration) {
timer := time.NewTimer(delay) timer := time.NewTimer(delay)
defer timer.Stop() defer timer.Stop()