feat: added logging

Author: thulasirajkomminar

CHANGELOG.md

@@ -3,6 +3,7 @@
 ### Others
 
 1. [#68](https://github.com/InfluxCommunity/influxdb3-go/pull/68): Upgrade Go version to 1.22.
+2. [#74](https://github.com/InfluxCommunity/influxdb3-go/pull/74): Added logger.
 
 ## 0.6.0 [2024-03-01]
 

influxdb3/client.go

@@ -28,16 +28,20 @@ import (
 	"encoding/json"
 	"fmt"
 	"io"
+	"log/slog"
 	"mime"
 	"net/http"
 	"net/url"
+	"os"
 	"path"
 	"strconv"
 	"strings"
 
 	"github.com/apache/arrow/go/v15/arrow/flight"
 )
 
+var logger *slog.Logger
+
 // Client implements an InfluxDB client.
 type Client struct {
 	// Configuration options.
@@ -107,6 +111,11 @@ func New(config ClientConfig) (*Client, error) {
 		return nil, fmt.Errorf("flight client: %w", err)
 	}
 
+	// Initialize logger
+	logger = slog.New(slog.NewJSONHandler(os.Stdout, &slog.HandlerOptions{
+		Level: c.config.LogLevel,
+	}))
+
 	return c, nil
 }
 

influxdb3/config.go

@@ -25,11 +25,13 @@ package influxdb3
 import (
 	"errors"
 	"fmt"
-	"github.com/influxdata/line-protocol/v2/lineprotocol"
+	"log/slog"
 	"net/http"
 	"net/url"
 	"os"
 	"strconv"
+
+	"github.com/influxdata/line-protocol/v2/lineprotocol"
 )
 
 const (
@@ -74,6 +76,9 @@ type ClientConfig struct {
 
 	// Default HTTP headers to be included in requests
 	Headers http.Header
+
+	// LogLevel for the logger
+	LogLevel slog.Leveler
 }
 
 // validate validates the config.

influxdb3/point_values.go

@@ -70,7 +70,7 @@ func (pv *PointValues) SetTimestamp(timestamp time.Time) *PointValues {
 // SetTag sets a tag value and returns the modified PointValues
 func (pv *PointValues) SetTag(name string, value string) *PointValues {
 	if value == "" {
-		fmt.Printf("Empty tags has no effect, tag [%s], measurement [%s]\n", name, pv.MeasurementName)
+		logger.Debug(fmt.Sprintf("Empty tags has no effect, tag [%s], measurement [%s]", name, pv.MeasurementName))
 	} else {
 		pv.Tags[name] = value
 	}