Class: CI::Queue::Redis::BuildRecord

Inherits:
Object
  • Object
show all
Defined in:
lib/ci/queue/redis/build_record.rb

Instance Method Summary collapse

Constructor Details

#initialize(queue, redis, config) ⇒ BuildRecord

Returns a new instance of BuildRecord.



5
6
7
8
9
 
# File 'lib/ci/queue/redis/build_record.rb', line 5

def initialize(queue, redis, config)
  @queue = queue
  @redis = redis
  @config = config
end

Instance Method Details

#error_reports ⇒ Object 



56
57
58
 
# File 'lib/ci/queue/redis/build_record.rb', line 56

def error_reports
  redis.hgetall(key('error-reports'))
end

#failed_tests ⇒ Object 



19
20
21
 
# File 'lib/ci/queue/redis/build_record.rb', line 19

def failed_tests
  redis.hkeys(key('error-reports'))
end

#fetch_stats(stat_names) ⇒ Object 



60
61
62
63
64
65
 
# File 'lib/ci/queue/redis/build_record.rb', line 60

def fetch_stats(stat_names)
  counts = redis.pipelined do
    stat_names.each { |c| redis.hvals(key(c)) }
  end
  stat_names.zip(counts.map { |values| values.map(&:to_f).inject(:+).to_f }).to_h
end

#pop_warnings ⇒ Object 



23
24
25
26
27
28
29
30
 
# File 'lib/ci/queue/redis/build_record.rb', line 23

def pop_warnings
  warnings = redis.multi do
    redis.lrange(key('warnings'), 0, -1)
    redis.del(key('warnings'))
  end.first

  warnings.map { |p| Marshal.load(p) }
end

#progress ⇒ Object 



11
12
13
 
# File 'lib/ci/queue/redis/build_record.rb', line 11

def progress
  @queue.progress
end

#queue_exhausted? ⇒ Boolean

Returns:

  • (Boolean) 


15
16
17
 
# File 'lib/ci/queue/redis/build_record.rb', line 15

def queue_exhausted?
  @queue.exhausted?
end

#record_error(id, payload, stats: nil) ⇒ Object 



36
37
38
39
40
41
42
43
44
45
46
 
# File 'lib/ci/queue/redis/build_record.rb', line 36

def record_error(id, payload, stats: nil)
  redis.pipelined do
    redis.hset(
      key('error-reports'),
      id.force_encoding(Encoding::BINARY),
      payload.force_encoding(Encoding::BINARY),
    )
    record_stats(stats)
  end
  nil
end

#record_success(id, stats: nil) ⇒ Object 



48
49
50
51
52
53
54
 
# File 'lib/ci/queue/redis/build_record.rb', line 48

def record_success(id, stats: nil)
  redis.pipelined do
    redis.hdel(key('error-reports'), id.force_encoding(Encoding::BINARY))
    record_stats(stats)
  end
  nil
end

#record_warning(type, attributes) ⇒ Object 



32
33
34
 
# File 'lib/ci/queue/redis/build_record.rb', line 32

def record_warning(type, attributes)
  redis.rpush(key('warnings'), Marshal.dump([type, attributes]))
end

#reset_stats(stat_names) ⇒ Object 



67
68
69
70
71
72
73
 
# File 'lib/ci/queue/redis/build_record.rb', line 67

def reset_stats(stat_names)
  redis.pipelined do
    stat_names.each do |stat_name|
      redis.hdel(key(stat_name), config.worker_id)
    end
  end
end