chris/styx
chris/styx
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

Mutating data without needing to get it back

Browse source
This commit is contained in:
Christopher Talib 2020-03-04 16:34:14 +01:00
parent f61fe566a5
commit fb270a1b66
1 changed files with 16 additions and 18 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

34
plugins/certstream.go
View file

@ -3,7 +3,6 @@ package plugins
import ( import (
"context" "context"
"encoding/json" "encoding/json"
"fmt"
"sync" "sync"
"github.com/CaliDog/certstream-go" "github.com/CaliDog/certstream-go"
@ -89,26 +88,25 @@ func (c *CertStreamPlugin) doRun(graphClient *dgo.Dgraph) {
logrus.Fatal(err) logrus.Fatal(err)
} }
mu.SetJson = marshaled mu.SetJson = marshaled
assigned, err := graphClient.NewTxn().Mutate(context.Background(), mu) _, err = graphClient.NewTxn().Mutate(context.Background(), mu)
if err != nil { if err != nil {
logrus.Fatal(err) logrus.Fatal(err)
} }
variables := map[string]string{"$id": assigned.Uids[mainNode.ID]} // variables := map[string]string{"$id": assigned.Uids[mainNode.ID]}
q := `query Node($id: string){ // q := `query Node($id: string){
node(func: uid($id)) { // node(func: uid($id)) {
uid // uid
ID // ID
Type // type
Data // data
Created // dreated
Modified // modified
} // }
}` // }`
resp, err := graphClient.NewTxn().QueryWithVars(context.Background(), q, variables) // _, err := graphClient.NewTxn().QueryWithVars(context.Background(), q, variables)
if err != nil { // if err != nil {
logrus.Fatal(err) // logrus.Fatal(err)
} // }
fmt.Println(resp)
} }
} }