unkinben
0451894b48
## Summary
- Adds `Unkin::Ceph::Utils` facter module detecting ceph service instances via `systemctl list-units`, exposing `is_ceph_mon`, `is_ceph_mgr`, `is_ceph_mds`, `is_ceph_osd` booleans and a `ceph_services` hash of unit names
- Adds `profiles::ceph::mon`, `mgr`, `mds`, `osd` — each with `Boolean $ensure_running` that iterates discovered service instances and manages them as running and enabled
- Works across incus nodes (mon/mgr/mds/osd) and k8s compute/control nodes (osd only); verified on prodnxsr0001 which correctly reports `is_ceph_osd: true` and `ceph_services: {osd: [ceph-osd@5]}`
## Test plan
- [x] Noop deploy against prodnxsr0001.main.unkin.net passed cleanly
- [x] `ceph_services` fact returns correct service map
- [x] `is_ceph_osd` returns `True`, `is_ceph_mon` returns `False` as expected
- [x] Test on an incus/ceph node with mon/mgr/mds services
Reviewed-on: #459
57 lines
1.5 KiB
Ruby
57 lines
1.5 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
require 'facter'
|
|
|
|
# Detects active ceph service instances via systemctl and exposes facts
|
|
# for use in ceph service management profiles.
|
|
# rubocop:disable Style/ClassAndModuleChildren
|
|
module Unkin
|
|
module Ceph
|
|
# Detects active ceph service instances via systemctl and exposes Facter facts.
|
|
module Utils
|
|
TYPES = %w[mon mgr mds osd].freeze
|
|
|
|
def self.services
|
|
output = Facter::Core::Execution.execute(
|
|
'systemctl list-units "ceph*" --no-legend --plain --all 2>/dev/null',
|
|
on_fail: ''
|
|
)
|
|
parse_units(output)
|
|
end
|
|
|
|
def self.parse_units(output)
|
|
result = TYPES.each_with_object({}) { |type, hash| hash[type] = [] }
|
|
output.each_line do |line|
|
|
unit = line.split.first
|
|
next unless unit
|
|
|
|
match_unit(result, unit)
|
|
end
|
|
result
|
|
end
|
|
|
|
def self.match_unit(result, unit)
|
|
TYPES.each do |type|
|
|
match = unit.match(/\Aceph-#{type}@(.+)\.service\z/)
|
|
result[type] << "ceph-#{type}@#{match[1]}" if match
|
|
end
|
|
end
|
|
|
|
TYPES.each do |type|
|
|
define_singleton_method(:"#{type}?") { !services[type].empty? }
|
|
end
|
|
end
|
|
end
|
|
end
|
|
# rubocop:enable Style/ClassAndModuleChildren
|
|
|
|
Facter.add('ceph_services') do
|
|
setcode { Unkin::Ceph::Utils.services }
|
|
end
|
|
|
|
Unkin::Ceph::Utils::TYPES.each do |type|
|
|
Facter.add("is_ceph_#{type}") do
|
|
setcode { Unkin::Ceph::Utils.public_send(:"#{type}?") }
|
|
end
|
|
end
|