Contents

module Vidar
  module K8s
    class Pods
      def initialize(namespace)
        @namespace = namespace
      end

      def all_ready?
        if items.empty?
          Log.error "Could not fetch pod list"
          return false
        end

        Log.line

        container_statuses.each(&:print)

        Log.line

        container_statuses.all?(&:ok?)
      end

      private

      attr_reader :namespace

      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
        @container_statuses ||= container_statuses_data.map { |status| ContainerStatus.new(status) }
      end

      def container_statuses_data
        items.map do |i|
          namespace = i.dig("metadata", "namespace")
          statuses = i.dig("status", "containerStatuses") || []
          statuses.each { |s| s["namespace"] = namespace }
          statuses
        end.flatten
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
vidar-0.3.4	lib/vidar/k8s/pods.rb
vidar-0.3.3	lib/vidar/k8s/pods.rb
vidar-0.3.2	lib/vidar/k8s/pods.rb