zookeeper-contrib/zookeeper-contrib-huebrowser/zkui/src/zkui/rest.py [102:155]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    def create(self, path, data=None, sequence=False, ephemeral=False):
        """ Create a new node. By default this call creates a persistent znode.

        You can also create an ephemeral or a sequential znode.
        """
        ri = path.rindex('/')
        head, name = path[:ri+1], path[ri+1:]
        if head != '/': head = head[:-1]

        flags = {
            'null': 'true' if data is None else 'false',
            'ephemeral': 'true' if ephemeral else 'false',
            'sequence': 'true' if sequence else 'false'
        }
        if ephemeral:
            if self._session:
                flags['session'] = self._session
            else:
                raise ZooKeeper.Error, 'You need a session '\
                    'to create an ephemeral node'
        flags = urllib.urlencode(flags)

        url = "%s/znodes/v1%s?op=create&name=%s&%s" % \
            (self._base, head, name, flags)

        return self._do_post(url, data)

    def set(self, path, data=None, version=-1, null=False):
        """ Set the value of node """
        url = "%s/znodes/v1%s?%s" % (self._base, path, \
            urllib.urlencode({
                'version': version,
                'null': 'true' if null else 'false'
        }))
        return self._do_put(url, data)

    def delete(self, path, version=-1):
        """ Delete a znode """
        if type(path) is list:
            map(lambda el: self.delete(el, version), path)
            return

        url = '%s/znodes/v1%s?%s' % (self._base, path, \
            urllib.urlencode({
                'version':version
        }))
        try:
            return self._do_delete(url)
        except urllib2.HTTPError, e:
            if e.code == 412:
                raise ZooKeeper.WrongVersion(path)
            elif e.code == 404:
                raise ZooKeeper.NotFound(path)
            raise
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



zookeeper-contrib/zookeeper-contrib-rest/src/python/zkrest.py [97:150]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    def create(self, path, data=None, sequence=False, ephemeral=False):
        """ Create a new node. By default this call creates a persistent znode.

        You can also create an ephemeral or a sequential znode.
        """
        ri = path.rindex('/')
        head, name = path[:ri+1], path[ri+1:]
        if head != '/': head = head[:-1]

        flags = {
            'null': 'true' if data is None else 'false',
            'ephemeral': 'true' if ephemeral else 'false',
            'sequence': 'true' if sequence else 'false'
        }
        if ephemeral:
            if self._session:
                flags['session'] = self._session
            else:
                raise ZooKeeper.Error, 'You need a session '\
                    'to create an ephemeral node'
        flags = urllib.urlencode(flags)

        url = "%s/znodes/v1%s?op=create&name=%s&%s" % \
            (self._base, head, name, flags)

        return self._do_post(url, data)

    def set(self, path, data=None, version=-1, null=False):
        """ Set the value of node """
        url = "%s/znodes/v1%s?%s" % (self._base, path, \
            urllib.urlencode({
                'version': version,
                'null': 'true' if null else 'false'
        }))
        return self._do_put(url, data)

    def delete(self, path, version=-1):
        """ Delete a znode """
        if type(path) is list:
            map(lambda el: self.delete(el, version), path)
            return

        url = '%s/znodes/v1%s?%s' % (self._base, path, \
            urllib.urlencode({
                'version':version
        }))
        try:
            return self._do_delete(url)
        except urllib2.HTTPError, e:
            if e.code == 412:
                raise ZooKeeper.WrongVersion(path)
            elif e.code == 404:
                raise ZooKeeper.NotFound(path)
            raise
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -