iconara / etcd-rb / 12

pending completion

Build # 12

Build Type

Pull #4

travis-ci

Committed by

mindreframer

Commit Message

comment

Pull Request Pull Request #4: proper cluster implementation with very robust failover and leader selection code

Run Details

354 of 354 new or added lines in 10 files covered. (100.0%)

413 of 446 relevant lines covered (92.6%)

37.72 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

95.45

/lib/etcd/observer.rb

module Etcd
  # @private
  class Observer
    def initialize(client, prefix, handler)
      @client = client
      @prefix = prefix
      @handler = handler
    end

    def run
      @running = true
      index = nil
      @thread = Thread.start do
        while @running
          @client.watch(@prefix, index: index) do |value, key, info|
            if @running
              index = info[:index]
              @handler.call(value, key, info)
            end
          end
        end
      end
      self
    end

    def cancel
      @running = false
      self
    end

    def join
      @thread.join
      self
    end
  end
end

1	module Etcd	4✔
2	# @private
3	class Observer	4✔
4	def initialize(client, prefix, handler)	4✔
5	@client = client	12✔
6	@prefix = prefix	12✔
7	@handler = handler	12✔
8	end
9
10	def run	4✔
11	@running = true	12✔
12	index = nil	12✔
13	@thread = Thread.start do	12✔
14	while @running	12✔
15	@client.watch(@prefix, index: index) do \|value, key, info\|	24✔
16	if @running	24✔
17	index = info[:index]	24✔
18	@handler.call(value, key, info)	24✔
19	end
20	end
21	end
22	end
23	self	12✔
24	end
25
26	def cancel	4✔
27	@running = false	12✔
28	self	12✔
29	end
30
31	def join	4✔
32	@thread.join	12✔
33	self	×
34	end
35	end
36	end

iconara / etcd-rb / 12

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous