cephmgr

Nov 8, 2016

Changes in this version

+ const DevicesValue

+ const ForceFormatValue

+ const PrivateIPv4Value

+ func AddDesiredDevice(etcdClient etcd.KeysAPI, device, nodeID string) error

+ func AddDesiredDir(etcdClient etcd.KeysAPI, dir, nodeID string) error

+ func ConnectToClusterAsAdmin(context *clusterd.Context, factory client.ConnectionFactory, ...) (client.Connection, error)

+ func GetAppliedOSDs(nodeID string, etcdClient etcd.KeysAPI) (map[int]string, error)

+ func GetClusterName(etcdClient etcd.KeysAPI) (string, error)

+ func GetCrushMap(adminConn client.Connection) (string, error)

+ func GetDesiredMonitors(etcdClient etcd.KeysAPI) (map[string]*CephMonitorConfig, error)

+ func NewCephService(factory client.ConnectionFactory, devices string, forceFormat bool, ...) *clusterd.ClusterService

+ func RemoveDesiredDevice(etcdClient etcd.KeysAPI, device, nodeID string) error

+ type CephMonitorConfig struct

+ Endpoint string

+ Name string

+ type ClusterInfo struct

+ AdminSecret string

+ FSID string

+ MonitorSecret string

+ Monitors map[string]*CephMonitorConfig

+ Name string

+ func LoadClusterInfo(etcdClient etcd.KeysAPI) (*ClusterInfo, error)

+ type ConnectionFactory interface

+ ConnectAsAdmin func(context *clusterd.Context, cephFactory client.ConnectionFactory) (client.Connection, error)

+ func NewConnectionFactory() ConnectionFactory

+ type Device struct

+ Dir bool

+ Name string

+ NodeID string