Class: Celluloid::Probe

Inherits:
Object
  • Object
show all
Includes:
Celluloid, Notifications
Defined in:
lib/celluloid/probe.rb

Constant Summary collapse

NOTIFICATIONS_TOPIC_BASE = 
"celluloid.events.%s".freeze
EVENTS_BUFFER = 
Queue.new

Constants included from Celluloid

BARE_OBJECT_WARNING_MESSAGE, LINKING_TIMEOUT, OWNER_IVAR, VERSION

Class Method Summary collapse

Instance Method Summary collapse

Methods included from Notifications

notifier, publish, #subscribe, #unsubscribe

Methods included from Celluloid

#abort, actor?, #after, #async, boot, #call_chain_id, cores, #current_actor, #defer, detect_recursion, #every, exception_handler, #exclusive, #exclusive?, #future, included, init, #link, #linked_to?, #links, mailbox, #monitor, #monitoring?, public_registry, publish, #receive, register_shutdown, running?, shutdown, #signal, #sleep, stack_dump, stack_summary, start, supervise, suspend, #tasks, #terminate, #timeout, #unlink, #unmonitor, uuid, version, #wait

Constructor Details

#initialize ⇒ Probe

Returns a new instance of Probe.



66
67
68
 
# File 'lib/celluloid/probe.rb', line 66

def initialize
  async.process_queue
end

Class Method Details

.actor_created(actor) ⇒ Object 



26
27
28
 
# File 'lib/celluloid/probe.rb', line 26

def actor_created(actor)
  trigger_event(:actor_created, actor)
end

.actor_died(actor) ⇒ Object 



34
35
36
 
# File 'lib/celluloid/probe.rb', line 34

def actor_died(actor)
  trigger_event(:actor_died, actor)
end

.actor_named(actor) ⇒ Object 



30
31
32
 
# File 'lib/celluloid/probe.rb', line 30

def actor_named(actor)
  trigger_event(:actor_named, actor)
end

.actors_linked(a, b) ⇒ Object 



38
39
40
41
42
 
# File 'lib/celluloid/probe.rb', line 38

def actors_linked(a, b)
  a = find_actor(a)
  b = find_actor(b)
  trigger_event(:actors_linked, a, b)
end

.run ⇒ Object 



17
18
19
20
 
# File 'lib/celluloid/probe.rb', line 17

def run
  # spawn the actor if not found
  supervise_as(:probe_actor) unless Actor[:probe_actor] && Actor[:probe_actor].alive?
end

.run_without_supervision ⇒ Object 



22
23
24
 
# File 'lib/celluloid/probe.rb', line 22

def run_without_supervision
  Actor[:probe_actor] = Celluloid::Probe.new
end

Instance Method Details

#dispatch_event(cmd, args) ⇒ Object 



77
78
79
 
# File 'lib/celluloid/probe.rb', line 77

def dispatch_event(cmd, args)
  publish(NOTIFICATIONS_TOPIC_BASE % cmd, args)
end

#process_queue ⇒ Object 



70
71
72
73
74
75
 
# File 'lib/celluloid/probe.rb', line 70

def process_queue
  until EVENTS_BUFFER.empty?
    event = EVENTS_BUFFER.pop
    dispatch_event(*event)
  end
end