Class: Async::Service::Controller

Inherits:
Container::Controller
  • Object
show all
Defined in:
lib/async/service/controller.rb

Overview

Controls multiple services and their lifecycle.

The controller manages starting, stopping, and monitoring multiple services within containers. It extends Async::Container::Controller to provide service-specific functionality.

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(services, **options) ⇒ Controller

Initialize a new controller with services.



35
36
37
38
39
 
# File 'lib/async/service/controller.rb', line 35

def initialize(services, **options)
  super(**options)
  
  @services = services
end

Instance Attribute Details

#services ⇒ Object (readonly)

All the services associated with this controller.



61
62
63
 
# File 'lib/async/service/controller.rb', line 61

def services
  @services
end

Class Method Details

.for(*services, **options) ⇒ Object

Create a controller for the given services.



28
29
30
 
# File 'lib/async/service/controller.rb', line 28

def self.for(*services, **options)
  self.new(services, **options)
end

.run(configuration, **options) ⇒ Object

Run a configuration of services.



20
21
22
 
# File 'lib/async/service/controller.rb', line 20

def self.run(configuration, **options)
  configuration.make_controller(**options).run
end

Instance Method Details

#make_policy ⇒ Object

Create a policy for managing child lifecycle events.



65
66
67
 
# File 'lib/async/service/controller.rb', line 65

def make_policy
  Policy::DEFAULT
end

#setup(container) ⇒ Object

Setup all services into the given container.



83
84
85
86
87
88
89
90
91
 
# File 'lib/async/service/controller.rb', line 83

def setup(container)
  super
  
  @services.each do |service|
    service.setup(container)
  end
  
  return container
end

#start ⇒ Object

Start all named services.



70
71
72
73
74
75
76
77
78
 
# File 'lib/async/service/controller.rb', line 70

def start
  @services.each do |service|
    service.start
  end
  
  super
  
  self.warmup
end

#stop(graceful = true) ⇒ Object

Stop all named services.



94
95
96
97
98
99
100
101
102
103
104
 
# File 'lib/async/service/controller.rb', line 94

def stop(graceful = true)
  @services.each do |service|
    begin
      service.stop
    rescue => error
      Console.error(self, error)
    end
  end
  
  super
end

#warmup ⇒ Object

Warm up the Ruby process by preloading gems, running GC, and compacting memory. This reduces startup latency and improves copy-on-write efficiency.



43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
 
# File 'lib/async/service/controller.rb', line 43

def warmup
  begin
    require "bundler"
    Bundler.require(:preload)
  rescue Bundler::GemfileNotFound, LoadError
    # Ignore.
  end
  
  if ::Process.respond_to?(:warmup)
    ::Process.warmup
  elsif ::GC.respond_to?(:compact)
    3.times{::GC.start}
    ::GC.compact
  end
end