The IoTReplicator object manages the replication process interfacing with the IoTCommunicator on one side and with the database on the other.
IoTReplicator(...) Constructor: create an IoTReplicator instance connect(...) Connect with an IoTCommunicator sync(agent_id, flags) Perform synchronization with the server database clear(agent_id) Delete data transmitted and acknowledged by the peer identified by agent_id
clear_class(agent_id, class_name) Delete data only from the specified class that has been transmitted and acknowledged by the peer identified by agent_id
stop() Stop the replicator enum_agents(callback_fn) Enumerate the active connections for this replicator. Call the callback function for each connection. The function signature must be as follows:
def iot_enum_agents_callback(repl, comm): passdestroy() Destroy the underlying replicator object Properties: agent_id The agent_id
of the nodelevel The level
of the nodecomm The underlying IoTCommunicator for the node