Zookeeper Server Check

module.exports = header: 'ZooKeeper Server Check', handler: ({options}) ->

Wait

  @call 'ryba/zookeeper/server/wait', once: true, options.wait

Check state

  @system.execute
    header: 'Healthy'
    cmd: "nc #{options.fqdn} #{options.config['clientPort']} <<< ruok | grep imok"

Check Registration

Execute these commands on the ZooKeeper host machine(s).

  cmds = for zookeeper in options.zookeeper_server
    "nc #{zookeeper.fqdn} #{zookeeper.port} <<< conf | sed -n 's/.*serverId=\\(.*\\)/\\1/p'"
  @system.execute
    header: 'Registration'
    cmd: cmds.join ';'
  , (err, data) ->
    return if err
    if options.zookeeper_server.length is 1 # Standalone mode
      unless data.stdout.trim().split('\n').sort().join(',') is '0'
        throw Error "Server is not properly registered"
    else # Replicated mode
      throw Error unless /\d+/.test server for server in data.stdout.trim().split('\n')
      # The following test only pass if all zookeeper servers are started.
      # However, we dont wait for all servers to be started but only a
      # quorum of servers.
      # unless stdout.trim().split('\n').sort().join(',') is [1..cmds.length].join(',')
      #   throw Error "Servers are not properly registered"