InfluxDB Connector for GoFr

docs/datasources/influxdb/page.md

@@ -0,0 +1,128 @@
+# InfluxDB
+GoFr supports injecting InfluxDB using an interface that defines the necessary methods to interact with InfluxDB v2+.  
+Any driver that implements this interface can be injected via the `app.AddInfluxDB()` method.
+
+---
+
+## Interface
+
+```go
+// InfluxDB defines the methods for interacting with an InfluxDB database.
+type InfluxDB interface {
+    Connect()
+    CreateOrganization(ctx context.Context, orgName string) (string, error)
+    DeleteOrganization(ctx context.Context, orgID string) error
+    ListOrganization(ctx context.Context) (map[string]string, error)
+
+    CreateBucket(ctx context.Context, orgID string, bucketName string, retentionPeriod time.Duration) (string, error)
+    DeleteBucket(ctx context.Context, orgID, bucketID string) error
+    ListBuckets(ctx context.Context, org string) (map[string]string, error)
+
+    Ping(ctx context.Context) (bool, error)
+    HealthCheck(ctx context.Context) (any, error)
+
+    Query(ctx context.Context, org string, fluxQuery string) ([]map[string]any, error)
+    WritePoints(ctx context.Context, bucket string, org string, points []container.InfluxPoint) error)
+
+    UseLogger(logger any)
+    UseMetrics(metrics any)
+    UseTracer(tracer any)
+}
+```
+
+This structure supports all essential InfluxDB operations including organization/bucket management, health checks, and metrics ingestion.
+
+Import the gofr's external driver for influxdb: 
+
+```bash
+go get gofr.dev/pkg/gofr/datasource/influxdb@latest
+```
+
+## Example
+```go
+package main
+
+import (
+"context"
+"fmt"
+"time"
+
+	"gofr.dev/pkg/gofr"
+	"gofr.dev/pkg/gofr/datasource/influxdb"
+)
+
+func main() {
+
+    // Create a new GoFr application
+    app := gofr.New() 
+
+	// Initialize InfluxDB client
+	client := influxdb.New(influxdb.Config{
+		Url:      "http://localhost:8086",
+		Username: "admin",
+		Password: "admin1234",
+		Token:    "<your-token>",
+	})
+
+	// Add InfluxDB to application context
+	app.AddInfluxDB(client)
+
+	// Sample route
+	app.GET("/greet", func(ctx *gofr.Context) (any, error) {
+		return "Hello World!", nil
+	})
+
+	// Ping InfluxDB
+	ok, err := client.Ping(context.Background())
+	if err != nil {
+		app.Logger().Debug(err)
+		return
+	}
+	app.Logger().Debug("InfluxDB connected: ", ok)
+
+	// Create organization
+	orgID, err := client.CreateOrganization(context.Background(), "demo-org")
+	if err != nil {
+		app.Logger().Debug(err)
+		return
+	}
+
+	// List organizations
+	orgs, _ := client.ListOrganization(context.Background())
+	app.Logger().Debug("Organizations: ")
+	for id, name := range orgs {
+		app.Logger().Debug(id, name)
+	}
+
+	// Create bucket
+	bucketID, err := client.CreateBucket(context.Background(), orgID, "demo-bucket")
+	if err != nil {
+		app.Logger().Debug(err)
+		return
+	}
+
+	// List buckets for organization
+	buckets, err := client.ListBuckets(context.Background(), "demo-org")
+	if err != nil {
+		app.Logger().Debug(err)
+		return
+	}
+	app.Logger().Debug("Buckets:", buckets)
+
+	// Delete bucket
+	if err := client.DeleteBucket(context.Background(), bucketID); err != nil {
+		app.Logger().Debug(err)
+		return
+	}
+	app.Logger().Debug("Bucket deleted successfully")
+
+	// Delete organization
+	if err := client.DeleteOrganization(context.Background(), orgID); err != nil {
+		app.Logger().Debug(err)
+		return
+	}
+	app.Logger().Debug("Organization deleted successfully")
+	// Start the server
+	app.Run()
+}
+```

docs/navigation.js

@@ -227,6 +227,11 @@ export const navigation = [
                 href: "/docs/datasources/elasticsearch",
                 desc: "Learn how to connect to and interact with elasticsearch in GoFr."
             },
+            {
+                title: "InfluxDB",
+                href: "/docs/datasources/influxdb",
+                desc: "Learn how to connect to and interact with influxdb in GoFr."
+            },
         ],
     },
     {

go.work

@@ -22,4 +22,5 @@ use (
 	./pkg/gofr/datasource/scylladb
 	./pkg/gofr/datasource/solr
 	./pkg/gofr/datasource/surrealdb
+	pkg/gofr/datasource/influxdb
 )

pkg/gofr/cmd/request_test.go

@@ -44,7 +44,6 @@ func TestRequest_Bind(t *testing.T) {
 
 	osHostName, _ := os.Hostname()
 
-	//nolint:usetesting // Comparing context.Background() directly is intentional and safe in this case.
 	assert.Equal(t, context.Background(), ctx, "TEST Failed.\n context is not context.Background.")
 
 	assert.Equal(t, osHostName, hostName, "TEST Failed.\n Hostname did not match.")

pkg/gofr/container/container.go

@@ -67,6 +67,7 @@ type Container struct {
 	Elasticsearch Elasticsearch
 	Oracle        OracleDB
 	Couchbase     Couchbase
+	InfluxDB      InfluxDB
 
 	KVStore KVStore
 

pkg/gofr/container/datasources.go

@@ -4,6 +4,7 @@ import (
 	"bytes"
 	"context"
 	"database/sql"
+	"time"
 
 	"github.com/redis/go-redis/v9"
 
@@ -776,3 +777,48 @@ type CouchbaseProvider interface {
 
 	provider
 }
+
+// InfluxDB defines the operations required to interact with an InfluxDB instance.
+type InfluxDB interface {
+	// CreateOrganization create new bucket in the influxdb
+	CreateOrganization(ctx context.Context, org string) (string, error)
+
+	// DeleteOrganization deletes a organization under the specified organization.
+	DeleteOrganization(ctx context.Context, orgID string) error
+
+	// ListOrganization list all the available organization
+	ListOrganization(ctx context.Context) (orgs map[string]string, err error)
+
+	// WritePoint writes one time-series points to a bucket.
+	// 'points' should follow the line protocol format or structured map format.
+	WritePoint(ctx context.Context, org, bucket string,
+		measurement string,
+		tags map[string]string,
+		fields map[string]any,
+		timestamp time.Time) error
+
+	// Query runs a Flux query and returns the result as a slice of maps,
+	// where each map is a row with column name-value pairs.
+	Query(ctx context.Context, fluxQuery string) ([]map[string]any, error)
+
+	// CreateBucket creates a new bucket under the specified organization.
+	CreateBucket(ctx context.Context, org, bucket string) (string, error)
+
+	// DeleteBucket deletes a bucketId with bucketID
+	DeleteBucket(ctx context.Context, bucketID string) error
+
+	// ListBuckets lists all buckets under the specified organization.
+	ListBuckets(ctx context.Context, org string) (map[string]string, error)
+
+	// Ping checks if the InfluxDB instance is reachable and healthy.
+	Ping(ctx context.Context) (bool, error)
+
+	HealthChecker
+}
+
+// InfluxDBProvider an interface that extends InfluxDB with additional methods for logging, metrics, and connection management.
+type InfluxDBProvider interface {
+	InfluxDB
+
+	provider
+}

pkg/gofr/container/health.go

@@ -69,6 +69,7 @@ func checkExternalDBHealth(ctx context.Context, c *Container, healthMap map[stri
 		"elasticsearch": c.Elasticsearch,
 		"oracle":        c.Oracle,
 		"couchbase":     c.Couchbase,
+		"influx":        c.InfluxDB,
 	}
 
 	for name, service := range services {