Schema: Parse column type

client.go

@@ -18,15 +18,15 @@ import (
 // OvsdbClient is an OVSDB client
 type OvsdbClient struct {
 	rpcClient     *rpc2.Client
-	Schema        map[string]DatabaseSchema
+	Schema        map[string]*DatabaseSchema
 	handlers      []NotificationHandler
 	handlersMutex *sync.Mutex
 }
 
 func newOvsdbClient(c *rpc2.Client) *OvsdbClient {
 	ovs := &OvsdbClient{
 		rpcClient:     c,
-		Schema:        make(map[string]DatabaseSchema),
+		Schema:        make(map[string]*DatabaseSchema),
 		handlersMutex: &sync.Mutex{},
 	}
 	return ovs
@@ -108,7 +108,7 @@ func newRPC2Client(conn net.Conn) (*OvsdbClient, error) {
 	for _, db := range dbs {
 		schema, err := ovs.GetSchema(db)
 		if err == nil {
-			ovs.Schema[db] = *schema
+			ovs.Schema[db] = schema
 		} else {
 			c.Close()
 			return nil, err
@@ -232,7 +232,7 @@ func (ovs OvsdbClient) GetSchema(dbName string) (*DatabaseSchema, error) {
 	if err != nil {
 		return nil, err
 	}
-	ovs.Schema[dbName] = reply
+	ovs.Schema[dbName] = &reply
 	return &reply, err
 }
 

example/print_schema/print_schema.go

@@ -0,0 +1,46 @@
+package main
+
+import (
+	"encoding/json"
+	"flag"
+	"fmt"
+	"io/ioutil"
+	"log"
+	"os"
+
+	"github.com/ebay/libovsdb"
+)
+
+func usage() {
+	fmt.Fprintf(os.Stderr, "Print schema information:\n")
+	fmt.Fprintf(os.Stderr, "\tprint_schemas OVS_SCHEMA\n")
+}
+
+func main() {
+	log.SetFlags(0)
+	flag.Usage = usage
+	flag.Parse()
+
+	if len(flag.Args()) != 1 {
+		flag.Usage()
+		os.Exit(2)
+	}
+
+	schemaFile, err := os.Open(flag.Args()[0])
+	if err != nil {
+		log.Fatal(err)
+	}
+	defer schemaFile.Close()
+
+	schemaBytes, err := ioutil.ReadAll(schemaFile)
+	if err != nil {
+		log.Fatal(err)
+	}
+
+	schema := libovsdb.DatabaseSchema{}
+	//if err := schema.Unmarshal(schemaBytes); err != nil {
+	if err := json.Unmarshal(schemaBytes, &schema); err != nil {
+		log.Fatal(err)
+	}
+	schema.Print(os.Stdout)
+}