draft

README

Draft

Draft is a simple, easy to use, and lightweight micro service in memory graph store written in go.

Please note that this is still under development and not ready for production use! The API is not stable and updates may introduce breaking changes.

Run GRPC server

# example with running with `go run`
# assuming you are in cmd
$ go run *.go
2020-05-06 05:04:46  file=service.go:206 level=info Starting [service] draft.srv
2020-05-06 05:04:46  file=grpc.go:845 level=info Server [grpc] Listening on [::]:40921
2020-05-06 05:04:46  file=grpc.go:676 level=info Registry [mdns] Registering node: draft.srv-df0497ec-83c6-46f9-83ed-183d0e1801da

# example with running with `go run`
# assuming you are in cmd
$ go run *.go -addr :1234 -name example.draft.service.name
2020-05-06 05:06:44  file=service.go:206 level=info Starting [service] example.draft.service.name
2020-05-06 05:06:44  file=grpc.go:845 level=info Server [grpc] Listening on [::]:1234
2020-05-06 05:06:44  file=grpc.go:676 level=info Registry [mdns] Registering node: example.draft.service.name-14b61530-fcd8-4e43-860b-b0f842298094

Simple example client

Here is a very simple example client which will create two nodes and two edges between them and it will iterate over all the edges.

package main

import (
	"context"
	"flag"
	"io"
	"log"

	pb "github.com/jenmud/draft/service"
	"google.golang.org/grpc"
)

var (
	addr string = ":8000"
)

func init() {
	flag.StringVar(&addr, "addr", addr, "Server address and port to connect to.")
	flag.Parse()
}

func main() {
	ctx := context.Background()

	conn, err := grpc.DialContext(ctx, addr, grpc.WithInsecure(), grpc.WithBlock())
	if err != nil {
		log.Fatal(err)
	}

	defer conn.Close()

	client := pb.NewGraphClient(conn)

	n1 := pb.NodeReq{Uid: "node-1", Label: "Person"}
	n2 := pb.NodeReq{Uid: "node-2", Label: "Person"}

	_, err = client.AddNode(ctx, &n1)
	if err != nil {
		log.Fatal(err)
	}

	_, err = client.AddNode(ctx, &n2)
	if err != nil {
		log.Fatal(err)
	}

	client.AddEdge(ctx, &pb.EdgeReq{Uid: "edge-1", SourceUid: "node-1", Label: "knows", TargetUid: "node-1"})
	client.AddEdge(ctx, &pb.EdgeReq{Uid: "edge-2", SourceUid: "node-1", Label: "likes", TargetUid: "node-2"})

	estream, err := client.Edges(ctx, &pb.EdgesReq{})
	if err != nil {
		log.Printf("Error: %s", err)
	}

	for {
		e, err := estream.Recv()
		if err == io.EOF {
			break
		}

		log.Printf("Got Edge %s", e)
	}
}

Web

See draft lens