Integrate Go driver examples into automated build process

- Add examples execution to gremlin-go-integration-tests container
- Make server URLs configurable via environment variables
- Use specialized labels (person-go-ex, go-conn-ex) to isolate test data
- Build fails if any example fails to execute
- Replace port placeholder logic with getEnvOrDefaultString() helper
- Use configurable vertex labels in examples

Author: kirill-stepanishin

glv-examples/gremlin-go/connections.go

@@ -51,8 +51,8 @@ func withRemote() {
     <-prom
 
     // Simple query to verify connection
-    g.AddV().Iterate()
-    count, _ := g.V().Count().Next()
+    g.AddV("connection").Iterate()
+    count, _ := g.V().HasLabel("connection").Count().Next()
     fmt.Println("Vertex count:", *count)
 }
 
@@ -75,7 +75,7 @@ func withConfigs() {
 	defer driverRemoteConnection.Close()
 	g := gremlingo.Traversal_().WithRemote(driverRemoteConnection)
 
-    g.AddV().Iterate()
-    count, _ := g.V().Count().Next()
+    g.AddV("connection").Iterate()
+    count, _ := g.V().HasLabel("connection").Count().Next()
     fmt.Println("Vertex count:", *count)
 }

gremlin-go/docker-compose.yml

@@ -60,10 +60,16 @@ services:
       - RUN_BASIC_AUTH_INTEGRATION_TESTS=true
       - GREMLIN_SOCKET_SERVER_URL=ws://gremlin-socket-server-go
       - GREMLIN_SOCKET_SERVER_CONFIG_PATH=/go_app/gremlin-socket-server/conf/test-ws-gremlin.yaml
+      - VERTEX_LABEL=go-example
     working_dir: /go_app
     command: >
       bash -c "go install github.com/gotesttools/gotestfmt/v2/cmd/gotestfmt@latest
-      && go test -v -json ./... -race -covermode=atomic -coverprofile=\"coverage.out\" -coverpkg=./... | gotestfmt"
+      && go test -v -json ./... -race -covermode=atomic -coverprofile=\"coverage.out\" -coverpkg=./... | gotestfmt
+      && echo 'Running examples...'
+      && go run examples/basic_gremlin.go
+      && go run examples/connections.go
+      && go run examples/modern_traversals.go
+      && echo 'All examples completed successfully'"
     depends_on:
       gremlin-server-test:
         condition: service_healthy

gremlin-go/examples/basic_gremlin.go

@@ -21,12 +21,23 @@ package main
 
 import (
 	"fmt"
+	"os"
 
 	"github.com/apache/tinkerpop/gremlin-go/v3/driver"
 )
 
+func getEnvOrDefaultString(key string, defaultValue string) string {
+	value := os.Getenv(key)
+	if len(value) != 0 {
+		return value
+	}
+	return defaultValue
+}
+
 func main() {
-	driverRemoteConnection, err := gremlingo.NewDriverRemoteConnection("ws://localhost:8182/gremlin")
+	serverURL := getEnvOrDefaultString("GREMLIN_SERVER_URL", "ws://localhost:8182/gremlin")
+	vertexLabel := getEnvOrDefaultString("VERTEX_LABEL", "person")
+	driverRemoteConnection, err := gremlingo.NewDriverRemoteConnection(serverURL)
 	if err != nil {
 		fmt.Println(err)
 		return
@@ -35,9 +46,9 @@ func main() {
 	g := gremlingo.Traversal_().WithRemote(driverRemoteConnection)
 
 	// Basic Gremlin: adding and retrieving data
-	v1, err := g.AddV("person").Property("name", "marko").Next()
-	v2, err := g.AddV("person").Property("name", "stephen").Next()
-	v3, err := g.AddV("person").Property("name", "vadas").Next()
+	v1, err := g.AddV(vertexLabel).Property("name", "marko").Next()
+	v2, err := g.AddV(vertexLabel).Property("name", "stephen").Next()
+	v3, err := g.AddV(vertexLabel).Property("name", "vadas").Next()
 	v1Vertex, err := v1.GetVertex()
 	v2Vertex, err := v2.GetVertex()
 	v3Vertex, err := v3.GetVertex()
@@ -58,12 +69,12 @@ func main() {
 	}
 
 	// Retrieve the data from the "marko" vertex
-	marko, err := g.V().Has("person", "name", "marko").Values("name").Next()
+	marko, err := g.V().Has(vertexLabel, "name", "marko").Values("name").Next()
 	fmt.Println("name:", marko.GetString())
 
 	// Find the "marko" vertex and then traverse to the people he "knows" and return their data
-	peopleMarkoKnows, err := g.V().Has("person", "name", "marko").Out("knows").Values("name").ToList()
+	peopleMarkoKnows, err := g.V().Has(vertexLabel, "name", "marko").Out("knows").Values("name").ToList()
 	for _, person := range peopleMarkoKnows {
 		fmt.Println("marko knows", person.GetString())
 	}
-}
+}

gremlin-go/examples/connections.go

@@ -21,18 +21,30 @@ package main
 
 import (
 	"fmt"
+	"os"
 
 	"github.com/apache/tinkerpop/gremlin-go/v3/driver"
 )
 
+func getEnvOrDefaultString(key string, defaultValue string) string {
+	value := os.Getenv(key)
+	if len(value) != 0 {
+		return value
+	}
+	return defaultValue
+}
+
 func main() {
 	withRemote()
 	withConfigs()
 }
 
 func withRemote() {
-    // Creating the connection to the server
-    driverRemoteConnection, err := gremlingo.NewDriverRemoteConnection("ws://localhost:8182/gremlin")
+	serverURL := getEnvOrDefaultString("GREMLIN_SERVER_URL", "ws://localhost:8182/gremlin")
+	vertexLabel := getEnvOrDefaultString("VERTEX_LABEL", "connection")
+
+	// Creating the connection to the server
+	driverRemoteConnection, err := gremlingo.NewDriverRemoteConnection(serverURL)
 
 	// Error handling
 	if err != nil {
@@ -43,22 +55,24 @@ func withRemote() {
 	// Cleanup
 	defer driverRemoteConnection.Close()
 
-    // Creating the graph traversal
+	// Creating the graph traversal
 	g := gremlingo.Traversal_().WithRemote(driverRemoteConnection)
 
-    // Drop existing vertices
-    prom := g.V().Drop().Iterate()
-    <-prom
+	// Simple query to verify connection
+	g.AddV(vertexLabel).Iterate()
+	count, _ := g.V().Count().Next()
+	fmt.Println("Vertex count:", *count)
 
-    // Simple query to verify connection
-    g.AddV().Iterate()
-    count, _ := g.V().Count().Next()
-    fmt.Println("Vertex count:", *count)
+	// clean added data
+	g.V().HasLabel(vertexLabel).Drop().Iterate()
 }
 
 func withConfigs() {
+	serverURL := getEnvOrDefaultString("GREMLIN_SERVER_URL", "ws://localhost:8182/gremlin")
+	vertexLabel := getEnvOrDefaultString("VERTEX_LABEL", "connection")
+
 	// Connecting to the server with customized configurations
-	driverRemoteConnection, err := gremlingo.NewDriverRemoteConnection("ws://localhost:8182/gremlin",
+	driverRemoteConnection, err := gremlingo.NewDriverRemoteConnection(serverURL,
 		func(settings *gremlingo.DriverRemoteConnectionSettings) {
 			settings.TraversalSource = "g"
 			settings.NewConnectionThreshold = 4
@@ -75,7 +89,7 @@ func withConfigs() {
 	defer driverRemoteConnection.Close()
 	g := gremlingo.Traversal_().WithRemote(driverRemoteConnection)
 
-    g.AddV().Iterate()
-    count, _ := g.V().Count().Next()
-    fmt.Println("Vertex count:", *count)
-}
+	g.AddV(vertexLabel).Iterate()
+	count, _ := g.V().Count().Next()
+	fmt.Println("Vertex count:", *count)
+}

gremlin-go/examples/modern_traversals.go

@@ -21,6 +21,7 @@ package main
 
 import (
 	"fmt"
+	"os"
 
 	"github.com/apache/tinkerpop/gremlin-go/v3/driver"
 )
@@ -29,8 +30,17 @@ var __ = gremlingo.T__
 var T = gremlingo.T
 var P = gremlingo.P
 
+func getEnvOrDefaultString(key string, defaultValue string) string {
+	value := os.Getenv(key)
+	if len(value) != 0 {
+		return value
+	}
+	return defaultValue
+}
+
 func main() {
-	driverRemoteConnection, err := gremlingo.NewDriverRemoteConnection("ws://localhost:8182/gremlin")
+	serverURL := getEnvOrDefaultString("GREMLIN_SERVER_URL", "ws://localhost:8182/gremlin")
+	driverRemoteConnection, err := gremlingo.NewDriverRemoteConnection(serverURL)
 	if err != nil {
 		fmt.Println(err)
 		return