class Legion::Extensions::Scheduler::Transport::Messages::Refresh

Public Instance Methods

encrypt?() click to toggle source
# File lib/legion/extensions/scheduler/transport/messages/refresh.rb, line 15
def encrypt?
  false
end
expiration() click to toggle source
# File lib/legion/extensions/scheduler/transport/messages/refresh.rb, line 11
def expiration
  5000
end
message() click to toggle source
# File lib/legion/extensions/scheduler/transport/messages/refresh.rb, line 19
def message
  {
    function: 'refresh',
    runner_class: 'Legion::Extensions::Scheduler::Runners::Schedule'
  }
end
message_example() click to toggle source
# File lib/legion/extensions/scheduler/transport/messages/refresh.rb, line 26
def message_example
  { 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/extensions/scheduler/transport/messages/refresh.rb, line 3
def routing_key
  'schedule'
end
type() click to toggle source
# File lib/legion/extensions/scheduler/transport/messages/refresh.rb, line 7
def type
  'task'
end