Reactor

class AsyncoreReactor

Bases: object

logger = <logging.Logger object>

start()

add_timer_absolute(timeout, callback)

add_timer(delay, callback)

shutdown()

new_connection(address, connect_timeout, socket_options, connection_closed_callback, message_callback)

class AsyncoreConnection(map, address, connect_timeout, socket_options, connection_closed_callback, message_callback)

Bases: hazelcast.connection.Connection, asyncore.dispatcher

sent_protocol_bytes = False

handle_connect()

handle_read()

handle_write()

handle_close()

handle_error()

readable()

write(data)

Writes data to this connection when sending messages.

Parameters:data – (Data), data to be written to connection.

writable()

close(cause)

Closes the connection.

Parameters:cause – (Exception), the cause of closing the connection.

class Timer(end, timer_ended_cb, timer_canceled_cb)

Bases: object

canceled = False

cancel()

check_timer(now)