Function getSchemaOverNetwork

worker/schema.go:163–178

If the current node serves the group serve the schema or forward to relevant node TODO: Janardhan - if read fails try other servers serving same group

(ctx context.Context, gid uint32, s *pb.SchemaRequest, ch chan resultErr)

// to relevant node
// TODO: Janardhan - if read fails try other servers serving same group
func getSchemaOverNetwork(ctx context.Context, gid uint32, s *pb.SchemaRequest, ch chan resultErr) {
	if groups().ServesGroup(gid) {
		schema, e := getSchema(ctx, s)
		ch <- resultErr{result: schema, err: e}
		return
	}

	pl := groups().Leader(gid)
	if pl == nil {
		ch <- resultErr{err: conn.ErrNoConnection}
		return
	}
	c := pb.NewWorkerClient(pl.Get())
	schema, e := c.Schema(ctx, s)
	ch <- resultErr{result: schema, err: e}
}

// GetSchemaOverNetwork checks which group should be serving the schema
// according to fingerprint of the predicate and sends it to that instance.