Merge pull request #4 from ClickHouse/clickhouse-exporter-improvements

inline asyncs

Author: kgoralski

exporter/clickhouseexporter/exporter_logs.go

@@ -188,6 +188,28 @@ SETTINGS index_granularity=8192, ttl_only_drop_parts = 1;
                         ResourceAttributes,
                         LogAttributes
                         )`
+	inlineinsertLogsSQLTemplate = `INSERT INTO %s SETTINGS async_insert=1, wait_for_async_insert=0 (
+                        Timestamp,
+                        TraceId,
+                        SpanId,
+                        TraceFlags,
+                        SeverityText,
+                        SeverityNumber,
+                        ServiceName,
+                        Body,
+                        ResourceAttributes,
+                        LogAttributes
+                        ) VALUES (
+                                 ?,
+                                 ?,
+                                 ?,
+                                 ?,
+                                 ?,
+                                 ?,
+                                 ?,
+                                 ?,
+                                 ?,
+                                 ?)`
 )
 
 var driverName = "clickhouse" // for testing
@@ -274,5 +296,8 @@ func renderCreateLogsTableSQL(cfg *Config) string {
 }
 
 func renderInsertLogsSQL(cfg *Config) string {
+	if strings.HasPrefix(cfg.Endpoint, "tcp") && cfg.ConnectionParams["async_insert"] == "1" {
+		return fmt.Sprintf(inlineinsertLogsSQLTemplate, cfg.LogsTableName)
+	}
 	return fmt.Sprintf(insertLogsSQLTemplate, cfg.LogsTableName)
 }