zookeeper-contrib/zookeeper-contrib-huebrowser/zkui/src/zkui/rest.py [24:86]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
class RequestWithMethod(urllib2.Request):
    """ Request class that know how to set the method name """
    def __init__(self, *args, **kwargs):
        urllib2.Request.__init__(self, *args, **kwargs)
        self._method = None

    def get_method(self):
        return self._method or \
            urllib2.Request.get_method(self)

    def set_method(self, method):
        self._method = method

class ZooKeeper(object):

    class Error(Exception): pass

    class NotFound(Error): pass

    class ZNodeExists(Error): pass

    class InvalidSession(Error): pass

    class WrongVersion(Error): pass

    def __init__(self, uri = 'http://localhost:9998'):
        self._base = uri
        self._session = None

    def start_session(self, expire=5, id=None):
        """ Create a session and return the ID """
        if id is None:
            url = "%s/sessions/v1/?op=create&expire=%d" % (self._base, expire)
            self._session = self._do_post(url)['id']
        else:
            self._session = id
        return self._session

    def close_session(self):
        """ Close the session on the server """
        if self._session is not None:
            url = '%s/sessions/v1/%s' % (self._base, self._session)
            self._do_delete(url)
            self._session = None

    def heartbeat(self):
        """ Send a heartbeat request. This is needed in order to keep a session alive """
        if self._session is not None:
            url = '%s/sessions/v1/%s' % (self._base, self._session)
            self._do_put(url, '')

    @contextmanager
    def session(self, *args, **kwargs):
        """ Session handling using a context manager """
        yield self.start_session(*args, **kwargs)
        self.close_session()

    def get(self, path):
        """ Get a node """
        url = "%s/znodes/v1%s" % (self._base, path)
        return self._do_get(url)

    def get_children(self, path):
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



zookeeper-contrib/zookeeper-contrib-rest/src/python/zkrest.py [24:86]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
class RequestWithMethod(urllib2.Request):
    """ Request class that know how to set the method name """
    def __init__(self, *args, **kwargs):
        urllib2.Request.__init__(self, *args, **kwargs)
        self._method = None

    def get_method(self):
        return self._method or \
            urllib2.Request.get_method(self)

    def set_method(self, method):
        self._method = method

class ZooKeeper(object):

    class Error(Exception): pass

    class NotFound(Error): pass

    class ZNodeExists(Error): pass

    class InvalidSession(Error): pass

    class WrongVersion(Error): pass

    def __init__(self, uri = 'http://localhost:9998'):
        self._base = uri
        self._session = None

    def start_session(self, expire=5, id=None):
        """ Create a session and return the ID """
        if id is None:
            url = "%s/sessions/v1/?op=create&expire=%d" % (self._base, expire)
            self._session = self._do_post(url)['id']
        else:
            self._session = id
        return self._session

    def close_session(self):
        """ Close the session on the server """
        if self._session is not None:
            url = '%s/sessions/v1/%s' % (self._base, self._session)
            self._do_delete(url)
            self._session = None

    def heartbeat(self):
        """ Send a heartbeat request. This is needed in order to keep a session alive """
        if self._session is not None:
            url = '%s/sessions/v1/%s' % (self._base, self._session)
            self._do_put(url, '')

    @contextmanager
    def session(self, *args, **kwargs):
        """ Session handling using a context manager """
        yield self.start_session(*args, **kwargs)
        self.close_session()

    def get(self, path):
        """ Get a node """
        url = "%s/znodes/v1%s" % (self._base, path)
        return self._do_get(url)

    def get_children(self, path):
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -