class Legion::Transport::Messages::RequestClusterSecret

Public Instance Methods

encrypt?() click to toggle source
# File lib/legion/transport/messages/request_cluster_secret.rb, line 21
def encrypt?
  false
end
exchange() click to toggle source
# File lib/legion/transport/messages/request_cluster_secret.rb, line 16
def exchange
  require 'legion/transport/exchanges/node'
  Legion::Transport::Exchanges::Node
end
message() click to toggle source
# File lib/legion/transport/messages/request_cluster_secret.rb, line 7
def message
  { function: 'push_cluster_secret',
    node_name: Legion::Settings[:client][:name],
    queue_name: "node.#{Legion::Settings[:client][:name]}",
    runner_class: 'Legion::Extensions::Node::Runners::Crypt',
    # public_key: Base64.encode64(Legion::Crypt.public_key) }
    public_key: Legion::Crypt.public_key }
end
routing_key() click to toggle source
# File lib/legion/transport/messages/request_cluster_secret.rb, line 3
def routing_key
  'node.crypt.push_cluster_secret'
end
type() click to toggle source
# File lib/legion/transport/messages/request_cluster_secret.rb, line 25
def type
  'task'
end
validate() click to toggle source
# File lib/legion/transport/messages/request_cluster_secret.rb, line 29
def validate
  @valid = true
end