XWTf     None+0Only register locally registered process names with zookeeper if the name begins with the given prefix. Default is "" which will register every locally registered process in the Zookeeper services node.;An operation that will be called for trace level logging.   uses .5An operation that will be called for error logging.   uses .*The log level for the C Zookeper library.   uses .;The ACL to use for every node - see hzk documentation for . Note that if your nodes do not connect with the same identity, every node will need at least Read permission to all nodes created by this package.#Credentials for Zookeeper, see hzk  for details.6A no-op that can be used for either of the loggers in a. Because no actual I/O is performed, it fully evaluates the message so thunks do not build up. *Simple formatter for trace output through . fBy default all local names are registered with zookeeper, and only error messages are logged through . defaultConfig = Config { registerPrefix = "" , logTrace = nolog , logError = say . ("[C.D.P.Zookeeper: ERROR] - " ++) , zLogLevel = ZK.ZLogWarn , acl = OpenAclUnsafe , credentials = Nothing } Register a name and pid as a service in Zookeeper. The controller will monitor the pid and remove its child node from Zookeeper when it exits.HNames will be registered at "/distributed-process/services/<name>/<pid>"5Note: By default all locally registered names (using ) will be registered in Zookeeper under the same name by an MxAgent process. Use this function if you want to register an anonymous pid or use a different name than is registered with the local Process, or when you are using a - to exclude the automatic registration (see ). HGet a list of nodes advertised in Zookeeper. These are registered when : starts in path "/distributed-process/controllers/<pid>".3Note: this is included for API compatibility with distributed-process-p2py but its usage would suggest discovery patterns that could be made more efficient when using Zookeeper - i.e. just use  . 6Returns list of pids registered with the service name.Results are cached by the controller until they are invalidated by subsequent changes to the service node in Zookeeper, which is communicated through a X. Data will be fetched from Zookeeper only when it is changed and then requested again.BBroadcast a message to a specific service on all registered nodes.2Note: this is included for API compatibility with distributed-process-p2py but its usage would suggest discovery patterns that could be made more efficient when using Zookeeper - i.e. just use  nfSendCapableH to nfSend a broadcast directly to the registered process on each node.KBroadcast a message to all pids registered with a particular service name.tRegister a candidate process for election of a single process associated to the given global name, and returns the I of the elected global (which may or may not be on the local node). The  Process () argument is only evaluated if this node ends up being the elected host for the global. Calling this function subsequently on the same node for the same name will replace the current candidate computation with the new one.'Find a registered global by name - see .xRun a Zookeeper service process, and installs an MXAgent to automatically register all local names in Zookeeper using  . -zkController = zkControllerWith defaultConfigAs  but accept ( options rather than assuming defaults.eWait for zkController to startup and register iteself. This is only useful if you are *not* using a [ function to start your node, but rather starting the node yourself and using one of the  functions.dCreate a process runner that communicates through an MVar - so you can call process actions from IO]This is linked bidirectionally - if either the proxy or parent exits the other will as well.jCreate a new Cloud Haskell node on the provided IP/Port and start a Zookeeper-backed controller process () with a default configuration connected to the provided Zookeeper server list. Finally execute the supplied Process computation. 'bootstrap = bootstrapWith defaultConfigjCreate a new Cloud Haskell node on the provided IP/Port and start a Zookeeper-backed controller process (h) connected to the provided Zookeeper server list and finally execute the supplied Process computation.E !"#$%&'()*+,-./0 >The Zookeeper endpoint(s) -- comma separated list of host:port>The Zookeeper endpoint(s) -- comma separated list of host:port123456789:;<=>?@ABCDEF6Hostname or IP this Cloud Haskell node will listen on.+Port or port name this node will listen on.>The Zookeeper endpoint(s) -- comma separated list of host:portCloud Haskell G to use in the new node.+Process computation to run in the new node.controller configuration6Hostname or IP this Cloud Haskell node will listen on.+Port or port name this node will listen on.>The Zookeeper endpoint(s) -- comma separated list of host:portCloud Haskell G to use in the new node.+Process computation to run in the new node.HIJKL     / !"#$%&'()0/.-,+* 123456789:;<=>?@ABCDEFHIJKLM      !"#$%&&'()*+,--./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRST%distributed-process-zookeeper-0.2.0.0%Control.Distributed.Process.ZookeeperConfigregisterPrefixlogTracelogError zLogLevelacl credentialsnologsayTrace defaultConfig registerZKgetPeers getCapable nsendPeers nsendCapableregisterCandidate whereisGlobal zkControllerzkControllerWithwaitController bootstrap bootstrapWithdistributed-process-0.5.3/Control.Distributed.Process.Internal.Primitivessay hzk-2.1.0Database.Zookeeper.TypesZLogWarnAclListDatabase.ZookeeperaddAuthregisterWatcher*Control.Distributed.Process.Internal.Types ProcessIdspawnLinkedProxyState nodeCachemonPids candidatesspidproxyconnElectCommandExit GetGlobal GetRegistered ClearCacheCheckCandidateGlobalCandidateRegisterserverhandleGlobalCandidatemayElect getGlobalIdsgetPid getChildPids watchCachewatchRegistrationstopController hoistEither servicesNodecontrollersNode globalsNoderootNode createAssertpidBytes controller nfSendChannfSendcallZKcreatedistributed-static-0.3.1.0Control.Distributed.Static RemoteTable $fShowState $fNFDataElect $fBinaryElect$fNFDataCommand$fBinaryCommand