Sha256: 4ee8320ba9c117332950fae7ad7ec52a52330a572d3c3e162017930986fef14c
Contents?: true
Size: 706 Bytes
Versions: 2
Compression:
Stored size: 706 Bytes
Contents
require 'cellect/node_set' module Cellect module Client class NodeSet < Cellect::NodeSet attr_accessor :nodes def initialize self.nodes = { } super end protected def nodes_changed(nodes) self.nodes = { } nodes.each do |node| self.nodes[node] = zk.get("/nodes/#{ node }").first end end def setup watch_nodes zk.mkdir_p '/nodes' nodes_changed zk.children('/nodes', watch: true) end def watch_nodes zk.register('/nodes') do |event| nodes_changed zk.children('/nodes', watch: true) end end end end end
Version data entries
2 entries across 2 versions & 1 rubygems
Version | Path |
---|---|
cellect-client-0.0.2 | lib/cellect/client/node_set.rb |
cellect-client-0.0.1 | lib/cellect/client/node_set.rb |