Class: Legion::Extensions::Node::Transport::Messages::ClusterSettings

Inherits:
Transport::Message
  • Object
show all
Defined in:
lib/legion/extensions/node/transport/messages/cluster_settings.rb

Instance Method Summary collapse

Instance Method Details

#encrypt? ⇒ Boolean

Returns:

  • (Boolean) 


23
24
25
 
# File 'lib/legion/extensions/node/transport/messages/cluster_settings.rb', line 23

def encrypt?
  false
end

#exchange ⇒ Object 



15
16
17
 
# File 'lib/legion/extensions/node/transport/messages/cluster_settings.rb', line 15

def exchange
  Legion::Extensions::Node::Transport::Exchanges::ClusterControl
end

#message ⇒ Object 



27
28
29
30
31
32
33
 
# File 'lib/legion/extensions/node/transport/messages/cluster_settings.rb', line 27

def message
  Legion::Extensions::Node::ControlAuth.sign(
    function: 'update_settings',
    settings: @options[:settings],
    restart:  @options.fetch(:restart, false)
  )
end

#routing_key ⇒ Object 



11
12
13
 
# File 'lib/legion/extensions/node/transport/messages/cluster_settings.rb', line 11

def routing_key
  @options.fetch(:routing_key, 'settings')
end

#type ⇒ Object 



19
20
21
 
# File 'lib/legion/extensions/node/transport/messages/cluster_settings.rb', line 19

def type
  'task'
end

#validate ⇒ Object 



35
36
37
38
39
 
# File 'lib/legion/extensions/node/transport/messages/cluster_settings.rb', line 35

def validate
  raise 'settings must be a Hash' unless @options[:settings].is_a?(Hash)

  @valid = true
end