gremgo-neptune is a fork of qasaur/gremgo with alterations to make it compatible with AWS Neptune which is a "Fast, reliable graph database built for the cloud".
gremgo is a fast, efficient, and easy-to-use client for the TinkerPop graph database stack. It is a Gremlin language driver which uses WebSockets to interface with Gremlin Server and has a strong emphasis on concurrency and scalability. Please keep in mind that gremgo is still under heavy development and although effort is being made to fully cover gremgo with reliable tests, bugs may be present in several areas.
Modifications were made to gremgo in order to "support" AWS Neptune's lack of Gremlin-specific features, like no support query bindings among others. See differences in Gremlin support here: AWS Neptune Gremlin Implementation Differences
go get github.com/schwartzmx/gremgo-neptune
dep ensure
package main
import (
"fmt"
"log"
"github.com/schwartzmx/gremgo-neptune"
)
func main() {
errs := make(chan error)
go func(chan error) {
err := <-errs
log.Fatal("Lost connection to the database: " + err.Error())
}(errs) // Example of connection error handling logic
dialer := gremgo.NewDialer("ws://127.0.0.1:8182") // Returns a WebSocket dialer to connect to Gremlin Server
g, err := gremgo.Dial(dialer, errs) // Returns a gremgo client to interact with
if err != nil {
fmt.Println(err)
return
}
res, err := g.Execute( // Sends a query to Gremlin Server with bindings
"g.V('1234')"
)
if err != nil {
fmt.Println(err)
return
}
j, err := json.Marshal(res[0].Result.Data) // res will return a list of resultsets, where the data is a json.RawMessage
if err != nil {
fmt.Println(err)
return nil, err
}
fmt.Printf("%s", j)
}The plugin accepts authentication creating a secure dialer where credentials are setted. If the server where are you trying to connect needs authentication and you do not provide the credentials the complement will panic.
package main
import (
"fmt"
"log"
"github.com/schwartzmx/gremgo-neptune"
)
func main() {
errs := make(chan error)
go func(chan error) {
err := <-errs
log.Fatal("Lost connection to the database: " + err.Error())
}(errs) // Example of connection error handling logic
dialer := gremgo.NewSecureDialer("127.0.0.1:8182", "username", "password") // Returns a WebSocket dialer to connect to Gremlin Server
g, err := gremgo.Dial(dialer, errs) // Returns a gremgo client to interact with
if err != nil {
fmt.Println(err)
return
}
res, err := g.Execute( // Sends a query to Gremlin Server with bindings
"g.V('1234')"
)
if err != nil {
fmt.Println(err)
return
}
j, err := json.Marshal(res[0].Result.Data) // res will return a list of resultsets, where the data is a json.RawMessage
if err != nil {
fmt.Println(err)
return nil, err
}
fmt.Printf("%s", j)
}See LICENSE