otto-de/marathon-api

# This class represents a Marathon Queue element.
# See https://mesosphere.github.io/marathon/docs/rest-api.html#queue for full list of API's methods.
class Marathon::Queue < Marathon::Base

  attr_reader :app

  # Create a new queue element object.
  # ++hash++: Hash returned by API, including 'app' and 'delay'
  # ++marathon_instance++: MarathonInstance holding a connection to marathon
  def initialize(hash, marathon_instance = Marathon.singleton)
    super(hash, %w[delay])
    @app = Marathon::App.new(info[:app], marathon_instance, true)
    @marathon_instance = marathon_instance
  end

  def to_s
    "Marathon::Queue { :appId => #{app.id} :delay => #{delay} }"
  end

  class << self

    # Show content of the task queue.
    # Returns Array of Queue objects.
    def list
      Marathon.singleton.queues.list
    end
  end
end

# This class represents the Queue with all its elements
class Marathon::Queues
  def initialize(marathon_instance)
    @connection = marathon_instance.connection
  end

  # Show content of the task queue.
  # Returns Array of Queue objects.
  def list
    json = @connection.get('/v2/queue')['queue']
    json.map { |j| Marathon::Queue.new(j) }
  end

end