5.3.8. vlcp.protocol.zookeeper

Note

This document is generated from the source file.

View Source on GitHub

Created on 2016/9/13

author:think
class vlcp.protocol.zookeeper.ZooKeeper

ZooKeeper protocol

__init__()

Constructor

async_requests(connection, requests, container, priority=0)
Returns:(matchers, generator), where matchers are event matchers for the requests; generator is the routine to send to requests.
closed(connection)

routine for connection closed

error(connection)

routine for connection error

init(connection)

routine for connection initialization

keepalive(connection)

routine executed when there has been a long time since last data arrival. Check if the connection is down.

notconnected(connection)

routine for connect failed and not retrying

parse(connection, data, laststart)

Parse input data into events :param connection: connection object :param data: view for input data :param laststart: last parsed position :returns: (events, keep) where events are parsed events to send, keep is the unused data length to be keeped for next parse.

reconnect_init(connection)

routine for reconnect

requests(connection, requests, container, callback=None, priority=0)

Send requests by sequence, return all the results (including the lost ones)

Params connection:
 ZooKeeper connection
Params requests:
 a sequence of ZooKeeper requests
Params container:
 routine container of current routine
Params callback:
 if not None, callback(request, response) is called immediately after each response received
Returns:(responses, lost_responses, retry_requests), where responses is a list of responses corresponded to the requests (None if response is not received); lost_responses is a list of requests that are sent but the responses are lost due to connection lost, it is the caller’s responsibility to determine whether the call is succeeded or failed; retry_requests are the requests which are not sent and are safe to retry.
serialize(connection, event)

Serialize a write event to bytes, and return if it is EOF :param connection: connection object :param event: write event :returns: (bytes, EOF)

class vlcp.protocol.zookeeper.ZooKeeperConnectionStateEvent(*args, **kwargs)
exception vlcp.protocol.zookeeper.ZooKeeperException
class vlcp.protocol.zookeeper.ZooKeeperHandshakeEvent(*args, **kwargs)
class vlcp.protocol.zookeeper.ZooKeeperMessageEvent(*args, **kwargs)
exception vlcp.protocol.zookeeper.ZooKeeperProtocolException
exception vlcp.protocol.zookeeper.ZooKeeperRequestTooLargeException

Request is too large, which may break every thing, so we reject it

class vlcp.protocol.zookeeper.ZooKeeperResponseEvent(*args, **kwargs)
exception vlcp.protocol.zookeeper.ZooKeeperRetryException

Connection lost or not connected on handshake

exception vlcp.protocol.zookeeper.ZooKeeperSessionExpiredException

Handshake reports the session is expired

class vlcp.protocol.zookeeper.ZooKeeperWatcherEvent(*args, **kwargs)
class vlcp.protocol.zookeeper.ZooKeeperWriteEvent(*args, **kwargs)