Sha256: 504a40bcace29d693d233a344930aa0ecf2a22adb9f7f052dd4f324ed341247c
Contents?: true
Size: 1.08 KB
Versions: 58
Compression:
Stored size: 1.08 KB
Contents
class KuberKit::Actions::ServiceChecker
include KuberKit::Import[
"kubernetes.resources_fetcher",
"shell.local_shell",
"core.service_store",
"ui",
]
Contract Hash => Any
def call(options)
services = service_store.all_definitions.values.map(&:service_name).map(&:to_s)
enabled_services = KuberKit.current_configuration.enabled_services.map(&:to_s)
if enabled_services.any?
services = services.select{ |s| enabled_services.include?(s) }
end
disabled_services = KuberKit.current_configuration.disabled_services.map(&:to_s)
if disabled_services.any?
services = services.select{ |s| !disabled_services.include?(s) }
end
resources = resources_fetcher.call("deployments") + resources_fetcher.call("cronjobs")
missing_services = services.select{ |s| !resources.include?(s.gsub("_", "-")) }
ui.print_warning("Warning", "This command will only check services deployed using k8s")
ui.print_info("Missing", missing_services.inspect)
{}
rescue KuberKit::Error => e
ui.print_error("Error", e.message)
false
end
end
Version data entries
58 entries across 58 versions & 1 rubygems