module Dag::Client::ClusterValidation
Constants
- VALID_WHERE_KEYS
Public Instance Methods
cluster_norm?()
click to toggle source
# File lib/dag/client/cluster_validation.rb, line 27 def cluster_norm? 'norm' == cluster_status end
cluster_norm_or_ptfailed?()
click to toggle source
# File lib/dag/client/cluster_validation.rb, line 31 def cluster_norm_or_ptfailed? ['norm', 'ptfailed'].include?(cluster_status) end
cluster_restart_status?()
click to toggle source
# File lib/dag/client/cluster_validation.rb, line 35 def cluster_restart_status? ['norm', 'failed', 'ptfailed'].include?(cluster_status) end
cluster_status()
click to toggle source
# File lib/dag/client/cluster_validation.rb, line 4 def cluster_status return @cluster_status if @cluster_status if @cluster_info return @cluster_info['status'] end return unless @cluster_name @cluster_info = @api.cluster_info(@cluster_name) @cluster_status = @cluster_info['status'] @cluster_status end
valid_cluster_info_list_status?(status = nil)
click to toggle source
# File lib/dag/client/cluster_validation.rb, line 22 def valid_cluster_info_list_status?(status = nil) status = cluster_status if status.nil? ['init', 'reserved', 'stopped', 'starting', 'restarting', 'norm', 'failed', 'ptfailed', 'error'].include?(status) end
valid_cluster_status?()
click to toggle source
# File lib/dag/client/cluster_validation.rb, line 18 def valid_cluster_status? ['init', 'reserved', 'stopped', 'restarting', 'norm', 'failed', 'ptfailed'].include?(cluster_status) end
validate_cluster()
click to toggle source
# File lib/dag/client/cluster_validation.rb, line 39 def validate_cluster raise Dag::Client::ClusterNotOpen.new("cluster not opened") if @cluster_name.blank? raise Dag::Client::StatusInvalid.new("cluster is not valid status: #{cluster_status}") unless valid_cluster_status? end
validate_cluster_param_keys(params)
click to toggle source
# File lib/dag/client/cluster_validation.rb, line 50 def validate_cluster_param_keys(params) params.keys.each do |k| unless VALID_WHERE_KEYS.include?(k.to_sym) raise Dag::Client::ParameterInvalid.new("Invalid where condition: #{k}") end end end