Class: BanterWorker
- Inherits:
-
Object
- Object
- BanterWorker
- Includes:
- Mongoid::Document
- Defined in:
- lib/banter/web/models/banter_worker.rb
Class Method Summary collapse
-
.clear_current_message!(success = true) ⇒ Object
Clears the current message key for the worker.
- .record_current!(banter_message) ⇒ Object
-
.subscribers ⇒ Array
Unique subscriber classes.
- .worker_started ⇒ Object
- .worker_stopped ⇒ Object
Instance Method Summary collapse
Class Method Details
.clear_current_message!(success = true) ⇒ Object
Clears the current message key for the worker
53 54 55 56 57 58 59 60 61 62 |
# File 'lib/banter/web/models/banter_worker.rb', line 53 def self.(success = true) current. = nil current.job_count += 1 if success current.success_count += 1 else current.failed_count += 1 end current.save! end |
.record_current!(banter_message) ⇒ Object
46 47 48 49 |
# File 'lib/banter/web/models/banter_worker.rb', line 46 def self.record_current!() current. = .attributes current.save! end |
.subscribers ⇒ Array
Returns Unique subscriber classes.
41 42 43 |
# File 'lib/banter/web/models/banter_worker.rb', line 41 def self.subscribers distinct("worker_classes") end |
.worker_started ⇒ Object
23 24 25 26 27 28 29 30 31 32 33 |
# File 'lib/banter/web/models/banter_worker.rb', line 23 def self.worker_started server_instance = Banter::Server::SubscriberServer.instance worker = new(process_name: server_instance.process_name, pid: server_instance.pid, hostname: server_instance.hostname, started_at: Time.now, worker_classes: Array.wrap(server_instance.workers).map(&:worker_class).map(&:name)) worker.save! @@current = worker worker end |
.worker_stopped ⇒ Object
35 36 37 38 |
# File 'lib/banter/web/models/banter_worker.rb', line 35 def self.worker_stopped current.try(:stop!) @@current = nil end |
Instance Method Details
#executing? ⇒ Boolean
64 65 66 |
# File 'lib/banter/web/models/banter_worker.rb', line 64 def executing? .present? end |
#stop! ⇒ Object
68 69 70 71 |
# File 'lib/banter/web/models/banter_worker.rb', line 68 def stop! self.stopped_at = Time.now save! end |