Getting transport is closing on client.NewDgraphClient

[akshaydeo]

Versions

Package	Version
Dgraph DB	0.8.1
Dgraph Client	From branch 0.8.1
grpc	master/git-ref: 25b4a426b40c26c07c80af674b03db90b5bd4a60
x/net	master/git-ref: 1c05540f6879653db88113bc4a2b70aec4bd491f
go	go1.8.3 darwin/amd64

➜  ~ dgraph --version

Dgraph version   : v0.8.1
Commit SHA-1     : 39a0f3f
Commit timestamp : 2017-08-21 09:48:09 +1000
Branch           : HEAD

Copyright 2017 Dgraph Labs, Inc.

Licensed under AGPLv3.
For Dgraph official documentation, visit https://docs.dgraph.io.
For discussions about Dgraph     , visit https://discuss.dgraph.io.
To say hi to the community       , visit https://dgraph.slack.com.

Issue

Code I am using to connect

type Dgraph struct {
	Addresses []string
	conns     []*grpc.ClientConn
	client    *client.Dgraph
}

// This function connects to the underlying grpc server and creates dgraph connections
func Connect(addresses []string) (*Dgraph, error) {
	logger.I("Connecting to dgraph", addresses)
	var err error
	d := new(Dgraph)
	d.Addresses = addresses
	for _, address := range addresses {
		logger.D("Dialing GRPC")
		conn, err := grpc.Dial(address, grpc.WithInsecure(), grpc.WithBlock())
		if err != nil {
			return nil, err
		}
		logger.I("GRPC connections state", conn.GetState().String())
		d.conns = append(d.conns, conn)
	}
	logger.D("Creating dgraph client")
	d.client = client.NewDgraphClient(d.conns, client.DefaultOptions, os.TempDir())
	req := new(client.Req)
	req.SetQuery(fmt.Sprintf(GET_NODE_FOR_ID, "test", "test", "test"))
	_, err = d.client.Run(context.Background(), req)
	if err != nil {
		logger.E("Error while connecting to the dgraph", err)
	}
	return d, err
}

Logs I get

Connecting to dgraph [127.0.0.1:8080]
Dialing GRPC
GRPC connections state READY
Creating dgraph client
Error while connecting to the dgraph rpc error: code = Unavailable desc = transport is closing

[pawanrawal]

Default port for grpc (--grpc_port) became 9080 from v0.8.0. Also Dial doesn't wait for the connection to be available, it returns immediately and connects in the background hence it doesn't fail there.

[akshaydeo]

Default port for grpc (--grpc_port) became 9080 from v0.8.0.

{"env":"test","host":"DV-MAC-AKSHAY-D.local","level":"info","msg":"[Connecting to dgraph [127.0.0.1:9080]]","service":"","time":"2017-08-22T09:23:17+05:30"}
{"env":"test","host":"DV-MAC-AKSHAY-D.local","level":"debug","msg":"[Dialing GRPC]","service":"","time":"2017-08-22T09:23:17+05:30"}
{"env":"test","host":"DV-MAC-AKSHAY-D.local","level":"info","msg":"[GRPC connections state READY]","service":"","time":"2017-08-22T09:23:17+05:30"}
{"env":"test","host":"DV-MAC-AKSHAY-D.local","level":"debug","msg":"[Creating dgraph client]","service":"","time":"2017-08-22T09:23:17+05:30"}
{"env":"test","host":"DV-MAC-AKSHAY-D.local","level":"error","msg":"[Error while connecting to the dgraph rpc error: code = Unknown desc = Got invalid keyword: id at root]","service":"","time":"2017-08-22T09:23:18+05:30"}

Also Dial doesn't wait for the connection to be available, it returns immediately and connects in the background hence it doesn't fail there.

I am using withBlock() as a param in dial. ref

conn, err := grpc.Dial(address, grpc.WithInsecure(), grpc.WithBlock())
if err != nil {
	return nil, err
}

[pawanrawal]

Ok, now there is a problem with your query. See the error message below.

Got invalid keyword: id at root

The syntax for specifying id changed from v0.8.0. See Changes here https://github.com/dgraph-io/dgraph/releases/tag/v0.8.0

[akshaydeo]

Aah, yes. It seems to be working. Will test it for a while and close the issue.

Thanks for the help @pawanrawal