otto-de/marathon-api

# This class represents a Marathon Event Subscriptions.
# See https://mesosphere.github.io/marathon/docs/rest-api.html#event-subscriptions for full list of API's methods.
class Marathon::EventSubscriptions

  def initialize(marathon_instance = Marathon.singleton)
    @connection = marathon_instance.connection
  end

  # List all event subscriber callback URLs.
  # Returns a list of strings/URLs.
  def list
    json = @connection.get('/v2/eventSubscriptions')
    json['callbackUrls']
  end

  # Register a callback URL as an event subscriber.
  # ++callbackUrl++: URL to which events should be posted.
  # Returns an event as hash.
  def register(callbackUrl)
    query = {}
    query[:callbackUrl] = callbackUrl
    json = @connection.post('/v2/eventSubscriptions', query)
    json
  end

  # Unregister a callback URL from the event subscribers list.
  # ++callbackUrl++: URL passed when the event subscription was created.
  # Returns an event as hash.
  def unregister(callbackUrl)
    query = {}
    query[:callbackUrl] = callbackUrl
    json = @connection.delete('/v2/eventSubscriptions', query)
    json
  end


  class << self
    # List all event subscriber callback URLs.
    # Returns a list of strings/URLs.
    def list
      Marathon.singleton.event_subscriptions.list
    end

    # Register a callback URL as an event subscriber.
    # ++callbackUrl++: URL to which events should be posted.
    # Returns an event as hash.
    def register(callbackUrl)
      Marathon.singleton.event_subscriptions.register(callbackUrl)
    end

    # Unregister a callback URL from the event subscribers list.
    # ++callbackUrl++: URL passed when the event subscription was created.
    # Returns an event as hash.
    def unregister(callbackUrl)
      Marathon.singleton.event_subscriptions.unregister(callbackUrl)
    end
  end
end