|
|
|
@ -71,7 +71,7 @@ func newCephScanTODO(cfg *ceph.Config) *cephScanTODO {
|
|
|
|
|
return todo |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
func (m *Cluster) scanCephMonitors(_ *ScanOptions) error { |
|
|
|
|
func (m *Cluster) scanCephMonitors(opts *ScanOptions) error { |
|
|
|
|
cfg, err := m.GetCephConfig() |
|
|
|
|
switch { |
|
|
|
|
case os.IsNotExist(err): |
|
|
|
@ -94,6 +94,10 @@ func (m *Cluster) scanCephMonitors(_ *ScanOptions) error {
|
|
|
|
|
todo.LogMissing(m.log) |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
return m.initCephMonitors(opts) |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
func (m *Cluster) initCephMonitors(_ *ScanOptions) error { |
|
|
|
|
// make sure every zone has one
|
|
|
|
|
m.ForEachZone(func(z *Zone) bool { |
|
|
|
|
_ = z.GetCephMonitors() |
|
|
|
|