Sha256: b858f0547c1d6837592921431df529606fe3a16bbd4acc8d4cdf8277410c1d17
Contents?: true
Size: 1.72 KB
Versions: 7
Compression:
Stored size: 1.72 KB
Contents
module Vidar
module K8s
class PodSet
def initialize(namespace:, filter: nil)
@namespace = namespace
@filter = filter
end
def deployed?
if items.empty?
Log.error "Could not fetch pod list"
return false
end
Log.line
container_statuses.each(&:print)
Log.line
container_statuses.all?(&:deployed?)
end
def success?
return false if container_statuses.empty?
container_statuses.all?(&:success?)
end
private
attr_reader :namespace, :filter
def items
@items ||= begin
json = JSON.parse(kubectl_get.strip)
json["items"] || []
end
end
def kubectl_get
if namespace == "all"
`kubectl get pods --all-namespaces -o json`
else
`kubectl get pods -n #{namespace} -o json`
end
end
def container_statuses
return all_container_statuses unless filter
all_container_statuses.select { |cs| cs.name.to_s.include?(filter) }
end
def all_container_statuses
@all_container_statuses ||= container_statuses_data.map { |status| ContainerStatus.new(status) }
end
def container_statuses_data
items.map do |i|
owner_references = i.dig("metadata", "ownerReferences") || []
kind = (owner_references[0] || {})["kind"]
namespace = i.dig("metadata", "namespace")
statuses = i.dig("status", "containerStatuses") || []
statuses.each do |s|
s["namespace"] = namespace
s["kind"] = kind
end
statuses
end.flatten
end
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems