Contents

module Spotdog
  class Datadog
    DEFAULT_PREFIX = "spotinstance"

    def self.send_price_history(api_key, spot_price_history, prefix: DEFAULT_PREFIX)
      self.new(api_key, prefix).send_price_history(spot_price_history)
    end

    def initialize(api_key, prefix)
      @client = Dogapi::Client.new(api_key)
      @prefix = prefix
    end

    def send_price_history(spot_price_history)
      groups_from(spot_price_history).each { |metric_name, price_history| @client.emit_points(metric_name, points_of(price_history)) }
    end

    private

    def groups_from(spot_price_history)
      spot_price_history.inject({}) do |result, spot_price|
        metric_name = metric_name_of(spot_price)
        result[metric_name] ||= []
        result[metric_name] << spot_price
        result
      end
    end

    def metric_name_of(spot_price)
      # "spotinstance.c4_xlarge.linux_vpc.ap-northeast-1b"
      [
        @prefix,
        spot_price[:instance_type].sub(".", "_"),
        os_type_of(spot_price),
        spot_price[:availability_zone].gsub("-", "_")
      ].join(".")
    end

    def machine_os_of(spot_price)
      case spot_price[:product_description]
      when /\ASUSE/
        "suse"
      when /\AWindows/
        "windows"
      else
        "linux"
      end
    end

    def machine_type_of(spot_price)
      spot_price[:product_description].include?("VPC") ? "vpc" : "classic"
    end

    def os_type_of(spot_price)
      "#{machine_os_of(spot_price)}_#{machine_type_of(spot_price)}"
    end

    def points_of(spot_price_history)
      spot_price_history.map { |spot_price| [spot_price[:timestamp], spot_price[:spot_price].to_f] }
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
spotdog-0.2.1	lib/spotdog/datadog.rb
spotdog-0.2.0	lib/spotdog/datadog.rb
spotdog-0.1.0	lib/spotdog/datadog.rb