Contents

class Kubes::Kubectl
  class Batch
    include Kubes::Util::Consider
    include Ordering

    def initialize(name, options={})
      @name, @options = name.to_s, options
    end

    def run
      sorted_files.each do |file|
        Kubes::Kubectl.run(@name, @options.merge(file: file))
      end
    end

    # kubes apply                   # {role: nil, resource: nil}
    # kubes apply clock             # {role: "clock", resource: nil}
    # kubes apply clock deployment  # {role: "clock", resource: "deployment"}
    def search_expr
      role, resource = @options[:role], @options[:resource]
      if role && resource
        "#{Kubes.root}/.kubes/output/#{role}/#{resource}.yaml"
      elsif role
        "#{Kubes.root}/.kubes/output/#{role}/*.yaml"
      else
        "#{Kubes.root}/.kubes/output/**/*.yaml"
      end
    end

    def files
      files = []
      Dir.glob(search_expr).each do |path|
        next unless process?(path)
        file = path.sub("#{Kubes.root}/", '')
        files << file
      end
      files
    end

    def process?(path)
      consider?(path) && two_levels_deep?(path)
    end

    def two_levels_deep?(path)
      rel_path = path.sub(%r{.*\.kubes/output/},'')
      rel_path.split('/').size == 2
    end
  end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
kubes-0.2.6	lib/kubes/kubectl/batch.rb
kubes-0.2.5	lib/kubes/kubectl/batch.rb
kubes-0.2.4	lib/kubes/kubectl/batch.rb
kubes-0.2.3	lib/kubes/kubectl/batch.rb
kubes-0.2.2	lib/kubes/kubectl/batch.rb
kubes-0.2.1	lib/kubes/kubectl/batch.rb
kubes-0.2.0	lib/kubes/kubectl/batch.rb