Class: Legion::Extensions::Scheduler::Transport::Messages::Refresh
- Inherits:
-
Transport::Message
- Object
- Transport::Message
- Legion::Extensions::Scheduler::Transport::Messages::Refresh
- Defined in:
- lib/legion/extensions/scheduler/transport/messages/refresh.rb
Instance Method Summary collapse
- #encrypt? ⇒ Boolean
- #expiration ⇒ Object
- #message ⇒ Object
- #message_example ⇒ Object
- #routing_key ⇒ Object
- #type ⇒ Object
Instance Method Details
#encrypt? ⇒ Boolean
15 16 17 |
# File 'lib/legion/extensions/scheduler/transport/messages/refresh.rb', line 15 def encrypt? false end |
#expiration ⇒ Object
11 12 13 |
# File 'lib/legion/extensions/scheduler/transport/messages/refresh.rb', line 11 def expiration 5000 end |
#message ⇒ Object
19 20 21 22 23 24 |
# File 'lib/legion/extensions/scheduler/transport/messages/refresh.rb', line 19 def { function: 'refresh', runner_class: 'Legion::Extensions::Scheduler::Runners::Schedule' } end |
#message_example ⇒ Object
26 27 28 29 30 31 32 33 |
# File 'lib/legion/extensions/scheduler/transport/messages/refresh.rb', line 26 def { 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 ⇒ Object
3 4 5 |
# File 'lib/legion/extensions/scheduler/transport/messages/refresh.rb', line 3 def routing_key 'schedule' end |
#type ⇒ Object
7 8 9 |
# File 'lib/legion/extensions/scheduler/transport/messages/refresh.rb', line 7 def type 'task' end |