InfluxDB Connector for GoFr

docker-compose.yml

@@ -0,0 +1,142 @@
+version: "3.8"
+
+services:
+  mongodb:
+    image: mongodb/mongodb-community-server:latest
+    container_name: mongodb
+    ports:
+      - "27017:27017"
+    environment:
+      MONGO_INITDB_ROOT_USERNAME: user
+      MONGO_INITDB_ROOT_PASSWORD: password
+
+  ftp-server:
+    image: delfer/alpine-ftp-server
+    ports:
+      - "21:21"
+      - "21000-21010:21000-21010"
+    environment:
+      USERS: "user|password"
+
+  opentsdb:
+    image: petergrace/opentsdb-docker:latest
+    container_name: gofr-opentsdb
+    ports:
+      - "4242:4242"
+
+  mysql:
+    image: mysql:8.0.30
+    container_name: gofr-mysql
+    environment:
+      MYSQL_ROOT_PASSWORD: password
+      MYSQL_DATABASE: test
+    ports:
+      - "2001:3306"
+
+  redis:
+    image: redis:7.0.5
+    container_name: gofr-redis
+    ports:
+      - "2002:6379"
+
+  solr:
+    image: solr
+    container_name: gofr-solr
+    command: solr -DzkRun
+    ports:
+      - "2020:8983"
+
+  zipkin:
+    image: openzipkin/zipkin:2
+    container_name: gofr-zipkin
+    ports:
+      - "2005:9411"
+
+  localstack:
+    image: localstack/localstack
+    ports:
+      - "4566:4566"
+      - "4510-4559:4510-4559"
+    tty: true
+    stdin_open: true
+    restart: unless-stopped
+
+  cassandra:
+    image: cassandra:latest
+    container_name: cassandra-node
+    ports:
+      - "9042:9042"
+    volumes:
+      - cassandra_data:/var/lib/cassandra
+
+  postgres:
+    image: postgres:15.1
+    container_name: gofr-pgsql
+    environment:
+      POSTGRES_DB: customers
+      POSTGRES_PASSWORD: root123
+    ports:
+      - "2006:5432"
+
+  mssql:
+    image: mcr.microsoft.com/azure-sql-edge
+    container_name: gofr-mssql
+    environment:
+      ACCEPT_EULA: "Y"
+      SA_PASSWORD: "reallyStrongPwd123"
+    ports:
+      - "2007:1433"
+
+  kafka:
+    image: bitnami/kafka:3.4
+    container_name: kafka-1
+    ports:
+      - "9092:9092"
+    environment:
+      KAFKA_ENABLE_KRAFT: "yes"
+      KAFKA_CFG_PROCESS_ROLES: "broker,controller"
+      KAFKA_CFG_CONTROLLER_LISTENER_NAMES: "CONTROLLER"
+      KAFKA_CFG_LISTENERS: "PLAINTEXT://:9092,CONTROLLER://:9093"
+      KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAP: "CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT"
+      KAFKA_CFG_ADVERTISED_LISTENERS: "PLAINTEXT://127.0.0.1:9092"
+      KAFKA_CFG_AUTO_CREATE_TOPICS_ENABLE: "true"
+      KAFKA_BROKER_ID: "1"
+      KAFKA_CFG_CONTROLLER_QUORUM_VOTERS: "[email protected]:9093"
+      ALLOW_PLAINTEXT_LISTENER: "yes"
+      KAFKA_CFG_NODE_ID: "1"
+    volumes:
+      - kafka_data:/bitnami
+
+  scylla:
+    image: scylladb/scylla
+    container_name: scylla
+    ports:
+      - "2025:9042"
+
+  nats:
+    image: nats:latest
+    container_name: nats-server
+    command: -js
+    ports:
+      - "4222:4222"
+      - "8222:8222"
+
+  surrealdb:
+    image: surrealdb/surrealdb:latest
+    container_name: surrealdb
+    command: start --bind 0.0.0.0:8000
+    ports:
+      - "8000:8000"
+
+  arangodb:
+    image: arangodb:latest
+    container_name: arangodb
+    ports:
+      - "8529:8529"
+    environment:
+      ARANGO_ROOT_PASSWORD: rootpassword
+    pull_policy: always
+
+volumes:
+  cassandra_data:
+  kafka_data:

docs/datasources/influxdb/page.md

@@ -0,0 +1,129 @@
+# 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 {
+		fmt.Println("Ping failed:", err)
+		return
+	}
+	fmt.Println("InfluxDB connected:", ok)
+
+	// Create organization
+	orgID, err := client.CreateOrganization(context.Background(), "demo-org")
+	if err != nil {
+		fmt.Println("CreateOrganization error:", err)
+		return
+	}
+
+	// List organizations
+	orgs, _ := client.ListOrganization(context.Background())
+	fmt.Println("Organizations:")
+	for id, name := range orgs {
+		fmt.Printf("- %s: %s\n", id, name)
+	}
+
+	// Create bucket
+	bucketID, err := client.CreateBucket(context.Background(), orgID, "demo-bucket", time.Hour)
+	if err != nil {
+		fmt.Println("CreateBucket error:", err)
+		return
+	}
+
+	// List buckets for organization
+	buckets, err := client.ListBuckets(context.Background(), "demo-org")
+	if err != nil {
+		fmt.Println("ListBuckets error:", err)
+		return
+	}
+	fmt.Println("Buckets:", buckets)
+
+	// Delete bucket
+	if err := client.DeleteBucket(context.Background(), orgID, bucketID); err != nil {
+		fmt.Println("DeleteBucket error:", err)
+		return
+	}
+	fmt.Println("Bucket deleted successfully")
+
+	// Delete organization
+	if err := client.DeleteOrganization(context.Background(), orgID); err != nil {
+		fmt.Println("DeleteOrganization error:", err)
+		return
+	}
+	fmt.Println("Organization deleted successfully")
+
+	// Start the server
+	app.Run()
+}
+```

go.work

@@ -1,6 +1,4 @@
-go 1.24.0
-
-toolchain go1.24.0
+go 1.24.2
 
 use (
 	.
@@ -22,4 +20,5 @@ use (
 	./pkg/gofr/datasource/scylladb
 	./pkg/gofr/datasource/solr
 	./pkg/gofr/datasource/surrealdb
+	pkg/gofr/datasource/influxdb
 )