Class: CI::Queue::Redis::BuildRecord
- Inherits:
-
Object
- Object
- CI::Queue::Redis::BuildRecord
- Defined in:
- lib/ci/queue/redis/build_record.rb
Instance Method Summary collapse
- #error_reports ⇒ Object
- #failed_tests ⇒ Object
- #fetch_stats(stat_names) ⇒ Object
- #flaky_reports ⇒ Object
-
#initialize(queue, redis, config) ⇒ BuildRecord
constructor
A new instance of BuildRecord.
- #max_test_failed? ⇒ Boolean
- #pop_warnings ⇒ Object
- #progress ⇒ Object
- #queue_exhausted? ⇒ Boolean
- #record_error(id, payload, stats: nil) ⇒ Object
- #record_flaky(id, stats: nil) ⇒ Object
- #record_success(id, stats: nil) ⇒ Object
- #record_warning(type, attributes) ⇒ Object
- #reset_stats(stat_names) ⇒ Object
Constructor Details
#initialize(queue, redis, config) ⇒ BuildRecord
Returns a new instance of BuildRecord.
6 7 8 9 10 |
# File 'lib/ci/queue/redis/build_record.rb', line 6 def initialize(queue, redis, config) @queue = queue @redis = redis @config = config end |
Instance Method Details
#error_reports ⇒ Object
77 78 79 |
# File 'lib/ci/queue/redis/build_record.rb', line 77 def error_reports redis.hgetall(key('error-reports')) end |
#failed_tests ⇒ Object
20 21 22 |
# File 'lib/ci/queue/redis/build_record.rb', line 20 def failed_tests redis.hkeys(key('error-reports')) end |
#fetch_stats(stat_names) ⇒ Object
85 86 87 88 89 90 91 92 93 |
# File 'lib/ci/queue/redis/build_record.rb', line 85 def fetch_stats(stat_names) counts = redis.pipelined do |pipeline| stat_names.each { |c| pipeline.hvals(key(c)) } end sum_counts = counts.map do |values| values.map(&:to_f).inject(:+).to_f end stat_names.zip(sum_counts).to_h end |
#flaky_reports ⇒ Object
81 82 83 |
# File 'lib/ci/queue/redis/build_record.rb', line 81 def flaky_reports redis.smembers(key('flaky-reports')) end |
#max_test_failed? ⇒ Boolean
71 72 73 74 75 |
# File 'lib/ci/queue/redis/build_record.rb', line 71 def max_test_failed? return false if config.max_test_failed.nil? @queue.test_failures >= config.max_test_failed end |
#pop_warnings ⇒ Object
24 25 26 27 28 29 30 31 |
# File 'lib/ci/queue/redis/build_record.rb', line 24 def pop_warnings warnings = redis.multi do |transaction| transaction.lrange(key('warnings'), 0, -1) transaction.del(key('warnings')) end.first warnings.map { |p| Marshal.load(p) } end |
#progress ⇒ Object
12 13 14 |
# File 'lib/ci/queue/redis/build_record.rb', line 12 def progress @queue.progress end |
#queue_exhausted? ⇒ Boolean
16 17 18 |
# File 'lib/ci/queue/redis/build_record.rb', line 16 def queue_exhausted? @queue.exhausted? end |
#record_error(id, payload, stats: nil) ⇒ Object
37 38 39 40 41 42 43 44 45 46 47 48 |
# File 'lib/ci/queue/redis/build_record.rb', line 37 def record_error(id, payload, stats: nil) redis.pipelined do |pipeline| pipeline.hset( key('error-reports'), id.dup.force_encoding(Encoding::BINARY), payload.dup.force_encoding(Encoding::BINARY), ) pipeline.expire(key('error-reports'), config.redis_ttl) record_stats(stats, pipeline: pipeline) end nil end |
#record_flaky(id, stats: nil) ⇒ Object
60 61 62 63 64 65 66 67 68 69 |
# File 'lib/ci/queue/redis/build_record.rb', line 60 def record_flaky(id, stats: nil) redis.pipelined do |pipeline| pipeline.sadd?( key('flaky-reports'), id.b ) pipeline.expire(key('flaky-reports'), config.redis_ttl) end nil end |
#record_success(id, stats: nil) ⇒ Object
50 51 52 53 54 55 56 57 58 |
# File 'lib/ci/queue/redis/build_record.rb', line 50 def record_success(id, stats: nil) error_reports_deleted_count, requeued_count, _ = redis.pipelined do |pipeline| pipeline.hdel(key('error-reports'), id.dup.force_encoding(Encoding::BINARY)) pipeline.hget(key('requeues-count'), id.b) record_stats(stats, pipeline: pipeline) end record_flaky(id) if error_reports_deleted_count.to_i > 0 || requeued_count.to_i > 0 nil end |
#record_warning(type, attributes) ⇒ Object
33 34 35 |
# File 'lib/ci/queue/redis/build_record.rb', line 33 def record_warning(type, attributes) redis.rpush(key('warnings'), Marshal.dump([type, attributes])) end |
#reset_stats(stat_names) ⇒ Object
95 96 97 98 99 100 101 |
# File 'lib/ci/queue/redis/build_record.rb', line 95 def reset_stats(stat_names) redis.pipelined do |pipeline| stat_names.each do |stat_name| pipeline.hdel(key(stat_name), config.worker_id) end end end |