Contents

# frozen_string_literal: true

require 'proxes/services/es'

module ProxES
  class StatusCheck < Sequel::Model
    plugin :single_table_inheritance, :type

    extend ProxES::Services::ES

    SOURCE_CALLS = {
      health: %i[cluster health],
      node_stats: %i[nodes stats]
    }.freeze

    def validate
      super
      validates_presence %i[name source]
    end

    def check
      raise 'Unimplemented'
    end

    def value
      raise 'Unimplemented'
    end

    def passed?
      return @result if defined? @result

      check
    end

    def source_result
      self.class.source_result(source)
    end

    def children; end

    def formatted(val = nil)
      val || value
    end

    def policy_class
      StatusCheckPolicy
    end

    class << self
      def source_result(source)
        @source_result ||= Hash.new do |h, k|
          h[k] = client
          SOURCE_CALLS[source.to_sym].each do |call|
            h[k] = h[k].send(call)
          end
          h[k]
        end
      end
    end
  end

  Dir.glob(File.expand_path('./status_checks', __dir__) + '/*.rb').each { |f| require f }
end

# Table: status_checks
# Columns:
#  id             | integer      | PRIMARY KEY AUTOINCREMENT
#  type           | varchar(255) |
#  name           | varchar(255) |
#  source         | varchar(255) |
#  required_value | varchar(255) |
#  order          | integer      | DEFAULT 1
#  created_at     | timestamp    | DEFAULT datetime(CURRENT_TIMESTAMP, 'localtime')
#  updated_at     | timestamp    | DEFAULT datetime(CURRENT_TIMESTAMP, 'localtime')
# Indexes:
#  sqlite_autoindex_status_checks_1 | UNIQUE (name)

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
proxes-0.10.1	lib/proxes/models/status_check.rb