Class: Megatest::Config
- Inherits:
-
Object
- Object
- Megatest::Config
- Defined in:
- lib/megatest/config.rb
Instance Attribute Summary collapse
-
#backtrace ⇒ Object
readonly
Returns the value of attribute backtrace.
-
#before_fork_callbacks ⇒ Object
readonly
Returns the value of attribute before_fork_callbacks.
-
#build_id ⇒ Object
Returns the value of attribute build_id.
-
#ci ⇒ Object
Returns the value of attribute ci.
-
#circuit_breaker ⇒ Object
readonly
Returns the value of attribute circuit_breaker.
- #colors(io = nil) ⇒ Object
-
#deprecations ⇒ Object
Returns the value of attribute deprecations.
-
#differ ⇒ Object
writeonly
Sets the attribute differ.
-
#global_setup_callbacks ⇒ Object
readonly
Returns the value of attribute global_setup_callbacks.
-
#heartbeat_frequency ⇒ Object
Returns the value of attribute heartbeat_frequency.
-
#job_index ⇒ Object
Returns the value of attribute job_index.
-
#jobs_count ⇒ Object
Returns the value of attribute jobs_count.
-
#load_paths ⇒ Object
Returns the value of attribute load_paths.
-
#max_retries ⇒ Object
Returns the value of attribute max_retries.
-
#minitest_compatibility ⇒ Object
Returns the value of attribute minitest_compatibility.
-
#pretty_printer ⇒ Object
writeonly
Sets the attribute pretty_printer.
- #program_name ⇒ Object
-
#queue_url ⇒ Object
Returns the value of attribute queue_url.
-
#retry_tolerance ⇒ Object
Returns the value of attribute retry_tolerance.
-
#seed ⇒ Object
Returns the value of attribute seed.
-
#selectors ⇒ Object
Returns the value of attribute selectors.
-
#worker_id ⇒ Object
Returns the value of attribute worker_id.
-
#worker_setup_callbacks ⇒ Object
readonly
Returns the value of attribute worker_setup_callbacks.
-
#workers_count ⇒ Object
Returns the value of attribute workers_count.
Instance Method Summary collapse
- #before_fork(&block) ⇒ Object
- #build_queue ⇒ Object
- #diff(expected, actual) ⇒ Object
- #global_setup(&block) ⇒ Object
-
#initialize(env) ⇒ Config
constructor
A new instance of Config.
- #job_setup(&block) ⇒ Object
- #max_consecutive_failures=(max) ⇒ Object
- #pretty_print(object) ⇒ Object (also: #pp)
-
#random ⇒ Object
We always return a new generator with the same seed as to best reproduce remote builds locally if the same seed is given.
- #retries? ⇒ Boolean
- #run_before_fork_callback ⇒ Object
- #run_global_setup_callbacks ⇒ Object
- #run_job_setup_callbacks(job_index) ⇒ Object
- #total_max_retries(size) ⇒ Object
- #valid_worker_index? ⇒ Boolean
Constructor Details
#initialize(env) ⇒ Config
Returns a new instance of Config.
145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 |
# File 'lib/megatest/config.rb', line 145 def initialize(env) @load_paths = ["test"] # For easier transition from other frameworks @retry_tolerance = 0.0 @max_retries = 0 @deprecations = true @full_backtrace = false @queue_url = nil @ci = false @build_id = nil @worker_id = nil @workers_count = 1 @jobs_count = 1 @colors = nil # auto @before_fork_callbacks = [] @global_setup_callbacks = [] @job_setup_callbacks = [] @heartbeat_frequency = 5 @backtrace = Backtrace.new @program_name = nil @circuit_breaker = CircuitBreaker.new(Float::INFINITY) @seed = Random.rand(0xFFFF) @differ = Differ.new(self) @pretty_printer = PrettyPrint.new(self) @minitest_compatibility = false @selectors = nil CIService.configure(self, env) end |
Instance Attribute Details
#backtrace ⇒ Object (readonly)
Returns the value of attribute backtrace.
141 142 143 |
# File 'lib/megatest/config.rb', line 141 def backtrace @backtrace end |
#before_fork_callbacks ⇒ Object (readonly)
Returns the value of attribute before_fork_callbacks.
141 142 143 |
# File 'lib/megatest/config.rb', line 141 def before_fork_callbacks @before_fork_callbacks end |
#build_id ⇒ Object
Returns the value of attribute build_id.
139 140 141 |
# File 'lib/megatest/config.rb', line 139 def build_id @build_id end |
#ci ⇒ Object
Returns the value of attribute ci.
139 140 141 |
# File 'lib/megatest/config.rb', line 139 def ci @ci end |
#circuit_breaker ⇒ Object (readonly)
Returns the value of attribute circuit_breaker.
141 142 143 |
# File 'lib/megatest/config.rb', line 141 def circuit_breaker @circuit_breaker end |
#colors(io = nil) ⇒ Object
193 194 195 196 197 198 199 200 201 202 203 204 205 206 |
# File 'lib/megatest/config.rb', line 193 def colors(io = nil) case @colors when true Output::ANSIColors when false Output::NoColors else if io && !io.tty? Output::NoColors else Output::ANSIColors end end end |
#deprecations ⇒ Object
Returns the value of attribute deprecations.
139 140 141 |
# File 'lib/megatest/config.rb', line 139 def deprecations @deprecations end |
#differ=(value) ⇒ Object (writeonly)
Sets the attribute differ
143 144 145 |
# File 'lib/megatest/config.rb', line 143 def differ=(value) @differ = value end |
#global_setup_callbacks ⇒ Object (readonly)
Returns the value of attribute global_setup_callbacks.
141 142 143 |
# File 'lib/megatest/config.rb', line 141 def global_setup_callbacks @global_setup_callbacks end |
#heartbeat_frequency ⇒ Object
Returns the value of attribute heartbeat_frequency.
139 140 141 |
# File 'lib/megatest/config.rb', line 139 def heartbeat_frequency @heartbeat_frequency end |
#job_index ⇒ Object
Returns the value of attribute job_index.
139 140 141 |
# File 'lib/megatest/config.rb', line 139 def job_index @job_index end |
#jobs_count ⇒ Object
Returns the value of attribute jobs_count.
139 140 141 |
# File 'lib/megatest/config.rb', line 139 def jobs_count @jobs_count end |
#load_paths ⇒ Object
Returns the value of attribute load_paths.
139 140 141 |
# File 'lib/megatest/config.rb', line 139 def load_paths @load_paths end |
#max_retries ⇒ Object
Returns the value of attribute max_retries.
139 140 141 |
# File 'lib/megatest/config.rb', line 139 def max_retries @max_retries end |
#minitest_compatibility ⇒ Object
Returns the value of attribute minitest_compatibility.
139 140 141 |
# File 'lib/megatest/config.rb', line 139 def minitest_compatibility @minitest_compatibility end |
#pretty_printer=(value) ⇒ Object (writeonly)
Sets the attribute pretty_printer
143 144 145 |
# File 'lib/megatest/config.rb', line 143 def pretty_printer=(value) @pretty_printer = value end |
#program_name ⇒ Object
173 174 175 |
# File 'lib/megatest/config.rb', line 173 def program_name @program_name || "megatest" end |
#queue_url ⇒ Object
Returns the value of attribute queue_url.
139 140 141 |
# File 'lib/megatest/config.rb', line 139 def queue_url @queue_url end |
#retry_tolerance ⇒ Object
Returns the value of attribute retry_tolerance.
139 140 141 |
# File 'lib/megatest/config.rb', line 139 def retry_tolerance @retry_tolerance end |
#seed ⇒ Object
Returns the value of attribute seed.
141 142 143 |
# File 'lib/megatest/config.rb', line 141 def seed @seed end |
#selectors ⇒ Object
Returns the value of attribute selectors.
139 140 141 |
# File 'lib/megatest/config.rb', line 139 def selectors @selectors end |
#worker_id ⇒ Object
Returns the value of attribute worker_id.
141 142 143 |
# File 'lib/megatest/config.rb', line 141 def worker_id @worker_id end |
#worker_setup_callbacks ⇒ Object (readonly)
Returns the value of attribute worker_setup_callbacks.
141 142 143 |
# File 'lib/megatest/config.rb', line 141 def worker_setup_callbacks @worker_setup_callbacks end |
#workers_count ⇒ Object
Returns the value of attribute workers_count.
141 142 143 |
# File 'lib/megatest/config.rb', line 141 def workers_count @workers_count end |
Instance Method Details
#before_fork(&block) ⇒ Object
247 248 249 |
# File 'lib/megatest/config.rb', line 247 def before_fork(&block) @before_fork_callbacks << block end |
#build_queue ⇒ Object
231 232 233 234 235 236 237 238 239 240 241 |
# File 'lib/megatest/config.rb', line 231 def build_queue case @queue_url when nil Queue.build(self) when /\Arediss?:/ require "megatest/redis_queue" RedisQueue.build(self) else raise ArgumentError, "Unsupported queue type: #{@queue_url.inspect}" end end |
#diff(expected, actual) ⇒ Object
212 213 214 |
# File 'lib/megatest/config.rb', line 212 def diff(expected, actual) @differ&.call(expected, actual) end |
#global_setup(&block) ⇒ Object
255 256 257 |
# File 'lib/megatest/config.rb', line 255 def global_setup(&block) @global_setup_callbacks << block end |
#job_setup(&block) ⇒ Object
263 264 265 |
# File 'lib/megatest/config.rb', line 263 def job_setup(&block) @job_setup_callbacks << block end |
#max_consecutive_failures=(max) ⇒ Object
208 209 210 |
# File 'lib/megatest/config.rb', line 208 def max_consecutive_failures=(max) @circuit_breaker = CircuitBreaker.new(max) end |
#pretty_print(object) ⇒ Object Also known as: pp
216 217 218 |
# File 'lib/megatest/config.rb', line 216 def pretty_print(object) @pretty_printer.pretty_print(object) end |
#random ⇒ Object
We always return a new generator with the same seed as to best reproduce remote builds locally if the same seed is given.
223 224 225 |
# File 'lib/megatest/config.rb', line 223 def random Random.new(@seed) end |
#retries? ⇒ Boolean
267 268 269 |
# File 'lib/megatest/config.rb', line 267 def retries? @max_retries.positive? end |
#run_before_fork_callback ⇒ Object
243 244 245 |
# File 'lib/megatest/config.rb', line 243 def run_before_fork_callback @before_fork_callback.each { |c| c.call(self) } end |
#run_global_setup_callbacks ⇒ Object
251 252 253 |
# File 'lib/megatest/config.rb', line 251 def run_global_setup_callbacks @global_setup_callbacks.each { |c| c.call(self) } end |
#run_job_setup_callbacks(job_index) ⇒ Object
259 260 261 |
# File 'lib/megatest/config.rb', line 259 def run_job_setup_callbacks(job_index) @job_setup_callbacks.each { |c| c.call(self, job_index) } end |
#total_max_retries(size) ⇒ Object
271 272 273 274 275 276 277 |
# File 'lib/megatest/config.rb', line 271 def total_max_retries(size) if @retry_tolerance.positive? (size * @retry_tolerance).ceil else @max_retries * size end end |
#valid_worker_index? ⇒ Boolean
189 190 191 |
# File 'lib/megatest/config.rb', line 189 def valid_worker_index? worker_id.is_a?(Integer) && worker_id.positive? && worker_id < workers_count end |