Class: Lepus::ProcessRegistry

Inherits:
Object
  • Object
show all
Defined in:
lib/lepus/process_registry.rb,
lib/lepus/process_registry/backend.rb,
lib/lepus/process_registry/file_backend.rb,
lib/lepus/process_registry/message_builder.rb,
lib/lepus/process_registry/rabbitmq_backend.rb

Overview

Process registry that delegates to a configurable backend. Default backend is FileBackend for local file-based storage. Use RabbitmqBackend to share process data across apps via web dashboard.

Defined Under Namespace

Modules: Backend Classes: FileBackend, MessageBuilder, RabbitmqBackend

Class Attribute Summary collapse

Class Method Summary collapse

Class Attribute Details

.backend ⇒ Object 



9
10
11
 
# File 'lib/lepus/process_registry.rb', line 9

def backend
  @backend ||= Lepus.config.build_process_registry_backend
end

Class Method Details

.add(process) ⇒ Object 



32
33
34
 
# File 'lib/lepus/process_registry.rb', line 32

def add(process)
  backend.add(process)
end

.all ⇒ Object 



52
53
54
 
# File 'lib/lepus/process_registry.rb', line 52

def all
  backend.all
end

.clear ⇒ Object 



60
61
62
 
# File 'lib/lepus/process_registry.rb', line 60

def clear
  backend.clear
end

.count ⇒ Object 



56
57
58
 
# File 'lib/lepus/process_registry.rb', line 56

def count
  backend.count
end

.delete(process) ⇒ Object 



40
41
42
 
# File 'lib/lepus/process_registry.rb', line 40

def delete(process)
  backend.delete(process)
end

.exists?(id) ⇒ Boolean

Returns:

  • (Boolean) 


48
49
50
 
# File 'lib/lepus/process_registry.rb', line 48

def exists?(id)
  backend.exists?(id)
end

.find(id) ⇒ Object 



44
45
46
 
# File 'lib/lepus/process_registry.rb', line 44

def find(id)
  backend.find(id)
end

.path ⇒ Object

For backward compatibility with tests that check @path



65
66
67
 
# File 'lib/lepus/process_registry.rb', line 65

def path
  backend.respond_to?(:path) ? backend.path : nil
end

.reset! ⇒ Object 



27
28
29
30
 
# File 'lib/lepus/process_registry.rb', line 27

def reset!
  stop
  start
end

.reset_backend! ⇒ Object 



15
16
17
 
# File 'lib/lepus/process_registry.rb', line 15

def reset_backend!
  @backend = nil
end

.start ⇒ Object 



19
20
21
 
# File 'lib/lepus/process_registry.rb', line 19

def start
  backend.start
end

.stop ⇒ Object 



23
24
25
 
# File 'lib/lepus/process_registry.rb', line 23

def stop
  backend.stop
end

.update(process, metrics: {}) ⇒ Object 



36
37
38
 
# File 'lib/lepus/process_registry.rb', line 36

def update(process, metrics: {})
  backend.update(process, metrics: metrics)
end