Module: Elasticsearch::API::Shutdown::Actions
- Included in:
- ShutdownClient
- Defined in:
- lib/elasticsearch/api/namespace/shutdown.rb,
lib/elasticsearch/api/actions/shutdown/get_node.rb,
lib/elasticsearch/api/actions/shutdown/put_node.rb,
lib/elasticsearch/api/actions/shutdown/delete_node.rb
Instance Method Summary collapse
-
#delete_node(arguments = {}) ⇒ Object
Removes a node from the shutdown list.
-
#get_node(arguments = {}) ⇒ Object
Retrieve status of a node or nodes that are currently marked as shutting down.
-
#put_node(arguments = {}) ⇒ Object
Adds a node to be shut down.
Instance Method Details
#delete_node(arguments = {}) ⇒ Object
Removes a node from the shutdown list. Designed for indirect use by ECE/ESS and ECK. Direct use is not supported.
32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 |
# File 'lib/elasticsearch/api/actions/shutdown/delete_node.rb', line 32 def delete_node(arguments = {}) request_opts = { endpoint: arguments[:endpoint] || 'shutdown.delete_node' } defined_params = [:node_id].each_with_object({}) do |variable, set_variables| set_variables[variable] = arguments[variable] if arguments.key?(variable) end request_opts[:defined_params] = defined_params unless defined_params.empty? raise ArgumentError, "Required argument 'node_id' missing" unless arguments[:node_id] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = nil _node_id = arguments.delete(:node_id) method = Elasticsearch::API::HTTP_DELETE path = "_nodes/#{Utils.__listify(_node_id)}/shutdown" params = {} Elasticsearch::API::Response.new( perform_request(method, path, params, body, headers, request_opts) ) end |
#get_node(arguments = {}) ⇒ Object
Retrieve status of a node or nodes that are currently marked as shutting down. Designed for indirect use by ECE/ESS and ECK. Direct use is not supported.
33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 |
# File 'lib/elasticsearch/api/actions/shutdown/get_node.rb', line 33 def get_node(arguments = {}) request_opts = { endpoint: arguments[:endpoint] || 'shutdown.get_node' } defined_params = [:node_id].each_with_object({}) do |variable, set_variables| set_variables[variable] = arguments[variable] if arguments.key?(variable) end request_opts[:defined_params] = defined_params unless defined_params.empty? arguments = arguments.clone headers = arguments.delete(:headers) || {} body = nil _node_id = arguments.delete(:node_id) method = Elasticsearch::API::HTTP_GET path = if _node_id "_nodes/#{Utils.__listify(_node_id)}/shutdown" else '_nodes/shutdown' end params = Utils.process_params(arguments) Elasticsearch::API::Response.new( perform_request(method, path, params, body, headers, request_opts) ) end |
#put_node(arguments = {}) ⇒ Object
Adds a node to be shut down. Designed for indirect use by ECE/ESS and ECK. Direct use is not supported.
33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 |
# File 'lib/elasticsearch/api/actions/shutdown/put_node.rb', line 33 def put_node(arguments = {}) request_opts = { endpoint: arguments[:endpoint] || 'shutdown.put_node' } defined_params = [:node_id].each_with_object({}) do |variable, set_variables| set_variables[variable] = arguments[variable] if arguments.key?(variable) end request_opts[:defined_params] = defined_params unless defined_params.empty? raise ArgumentError, "Required argument 'body' missing" unless arguments[:body] raise ArgumentError, "Required argument 'node_id' missing" unless arguments[:node_id] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = arguments.delete(:body) _node_id = arguments.delete(:node_id) method = Elasticsearch::API::HTTP_PUT path = "_nodes/#{Utils.__listify(_node_id)}/shutdown" params = {} Elasticsearch::API::Response.new( perform_request(method, path, params, body, headers, request_opts) ) end |