43 lines
1.2 KiB
Go
43 lines
1.2 KiB
Go
package main
|
|
|
|
import (
|
|
"github.com/ceph/go-ceph/rados"
|
|
"log"
|
|
"os"
|
|
)
|
|
|
|
func connectioninit(params params) *cephconnection {
|
|
cephconn := &cephconnection{}
|
|
var err error
|
|
if _, err := os.Stat(params.config); os.IsNotExist(err) {
|
|
log.Fatalf("Congif file not exists. Error: %v\n", err)
|
|
}
|
|
|
|
if _, err := os.Stat(params.keyring); os.IsNotExist(err) {
|
|
log.Fatalf("Keyring file not exists. Error: %v\n", err)
|
|
}
|
|
|
|
cephconn.conn, err = rados.NewConnWithClusterAndUser(params.cluster, params.user)
|
|
if err != nil {
|
|
log.Fatalf("Can't create connection with cluster:%v and user:%v. Error: %v\n", params.cluster, params.user, err)
|
|
}
|
|
|
|
if err = cephconn.conn.ReadConfigFile(params.config); err != nil {
|
|
log.Fatalf("Can't read config file. Error: %v\n", err)
|
|
}
|
|
|
|
if err = cephconn.conn.SetConfigOption("keyring", params.keyring); err != nil {
|
|
log.Fatalf("Can't set config option. Error: %v\n", err)
|
|
}
|
|
|
|
if err = cephconn.conn.Connect(); err != nil {
|
|
log.Fatalf("Failed to connect cluster. Error: %v\n", err)
|
|
}
|
|
|
|
cephconn.ioctx, err = cephconn.conn.OpenIOContext(params.pool)
|
|
if err != nil {
|
|
log.Fatalf("Can't open pool %v. Error: %v\n", params.pool, err)
|
|
}
|
|
return cephconn
|
|
}
|