diff --git a/ceph/ceph.go b/ceph/ceph.go index e2bfa6e..b9577a8 100644 --- a/ceph/ceph.go +++ b/ceph/ceph.go @@ -8,17 +8,6 @@ import ( "github.com/ceph/go-ceph/rados" ) -func getPoolSize(cephConn *cephConnection, params string) Poolinfo { - monRawAnswer := makeMonQuery(cephConn, map[string]string{"prefix": "osd pool get", "pool": params, - "format": "json", "var": "size"}) - monAnswer := Poolinfo{} - if err := json.Unmarshal([]byte(monRawAnswer), &monAnswer); err != nil { - log.Fatalf("Can't parse monitor answer. Error: %v", err) - } - return monAnswer - -} - func makeMonQuery(cephConn *cephConnection, query map[string]string) []byte { @@ -38,6 +27,7 @@ func makeMonQuery(cephConn *cephConnection, query map[string]string) []byte { func main() { var connect cephConnection var err error + var monRawAnswer []byte fmt.Println("Creating connection object") connect.conn,err = rados.NewConn() @@ -48,6 +38,10 @@ func main() { connect.conn.Connect() defer connect.conn.Shutdown() + monRawAnswer = makeMonQuery(&connect, map[string]string{"prefix": "osd dump", "format": "json"}) + + fmt.Println(monRawAnswer) + // poolnames,err := connect.conn.ListPools() // if err != nil { // log.Fatal("Cannot list pools")