updated

Signed-off-by: Fazle Rabbi Sarker <[email protected]>

Author: fr-sarker

go.mod

@@ -41,7 +41,7 @@ require (
 	k8s.io/klog/v2 v2.130.1
 	kmodules.xyz/client-go v0.32.9
 	kmodules.xyz/custom-resources v0.32.2
-	kubedb.dev/apimachinery v0.59.1-0.20251127121913-eb88286e9179
+	kubedb.dev/apimachinery v0.59.1-0.20251128053802-7e4412f0f42e
 	sigs.k8s.io/controller-runtime v0.20.4
 	xorm.io/xorm v1.3.9
 )

go.sum

@@ -578,8 +578,8 @@ kmodules.xyz/prober v0.32.0 h1:8Z6pFRAu8kP0wwX2BooPCRy2SE6ZkUMHQmZDH5VUEGY=
 kmodules.xyz/prober v0.32.0/go.mod h1:h0fH4m9DaIwuNZq85zOlWUvBycyy4LvCPMUUhpS3iSE=
 kmodules.xyz/resource-metadata v0.32.1 h1:hWQbL0Xb+GaF7qn+rY0CNh7FUfKZw29VBUKTxjHFGYI=
 kmodules.xyz/resource-metadata v0.32.1/go.mod h1:wHC24BVzKb1gzkDCSI5l9CXK4AKD5gMamxEqVys50lI=
-kubedb.dev/apimachinery v0.59.1-0.20251127121913-eb88286e9179 h1:WVBqv3xCtHbfIM40Kp0ITo6adi1DAB4PgfvEYC19+Dg=
-kubedb.dev/apimachinery v0.59.1-0.20251127121913-eb88286e9179/go.mod h1:iYx9X5Vn3NNahcqErfT9vIP2V+/Az3nnQi0x8sBfOZI=
+kubedb.dev/apimachinery v0.59.1-0.20251128053802-7e4412f0f42e h1:umlqLjRj9TQp7nsz4s7+k44HQ9TE5oqDuBtU4GCIdd4=
+kubedb.dev/apimachinery v0.59.1-0.20251128053802-7e4412f0f42e/go.mod h1:iYx9X5Vn3NNahcqErfT9vIP2V+/Az3nnQi0x8sBfOZI=
 kubeops.dev/operator-shard-manager v0.0.3 h1:Z2YOAfyQIjvHMwT4O56lR0l9z25s2tCVDO22u/XuYnw=
 kubeops.dev/operator-shard-manager v0.0.3/go.mod h1:2oRq5vnCaUxzE+qIiRuzB34PlqahiynE+sYqWu6AMIY=
 kubeops.dev/petset v0.0.14 h1:Lk3prjtm5AgR44qr2SX8elx6sF9PK1G0GYlv8AZd9OY=

neo4j/kubedb_client_builder.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"errors"
 	"fmt"
+	"time"
 
 	"strings"
 
@@ -111,7 +112,13 @@ func (o *KubeDBClientBuilder) GetNeo4jClient() (*Client, error) {
 	}
 
 	// Create driver and check for errors immediately
-	driver, err := neo4j.NewDriverWithContext(o.url, neo4j.BasicAuth(dbUser, dbPassword, ""))
+	driver, err := neo4j.NewDriverWithContext(o.url, neo4j.BasicAuth(dbUser, dbPassword, ""), func(c *neo4j.Config) {
+		c.SocketConnectTimeout = 60 * time.Second
+		c.ConnectionAcquisitionTimeout = 60 * time.Second
+		c.MaxTransactionRetryTime = 60 * time.Second
+		c.MaxConnectionLifetime = 30 * time.Minute
+		c.MaxConnectionPoolSize = 100
+	})
 	if o.db.Spec.DisableSecurity {
 		driver, err = neo4j.NewDriverWithContext(o.url, neo4j.NoAuth())
 	}

vendor/kubedb.dev/apimachinery/apis/kubedb/v1alpha2/neo4j_helpers.go

@@ -7,12 +7,14 @@ import (
 
 	catalog "kubedb.dev/apimachinery/apis/catalog/v1alpha1"
 	"kubedb.dev/apimachinery/apis/kubedb"
+	"kubedb.dev/apimachinery/crds"
 
 	core "k8s.io/api/core/v1"
 	meta "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/types"
 	"k8s.io/klog/v2"
 	"k8s.io/utils/pointer"
+	"kmodules.xyz/client-go/apiextensions"
 	coreutil "kmodules.xyz/client-go/core/v1"
 	meta_util "kmodules.xyz/client-go/meta"
 	"kmodules.xyz/client-go/policy/secomp"
@@ -21,6 +23,10 @@ import (
 	"sigs.k8s.io/controller-runtime/pkg/client"
 )
 
+func (_ Neo4j) CustomResourceDefinition() *apiextensions.CustomResourceDefinition {
+	return crds.MustCustomResourceDefinition(SchemeGroupVersion.WithResource(ResourcePluralNeo4j))
+}
+
 func (r *Neo4j) ResourceSingular() string {
 	return ResourceSingularNeo4j
 }

vendor/modules.txt

@@ -2739,7 +2739,7 @@ kmodules.xyz/prober/api/v1
 kmodules.xyz/resource-metadata/apis/node
 kmodules.xyz/resource-metadata/apis/node/v1alpha1
 kmodules.xyz/resource-metadata/crds
-# kubedb.dev/apimachinery v0.59.1-0.20251127121913-eb88286e9179
+# kubedb.dev/apimachinery v0.59.1-0.20251128053802-7e4412f0f42e
 ## explicit; go 1.24.0
 kubedb.dev/apimachinery/apis
 kubedb.dev/apimachinery/apis/archiver/v1alpha1