Reactor

class AsyncoreReactor(logger_extras=None)

Bases: object

logger = <Logger HazelcastClient.AsyncoreReactor (WARNING)>
start()
add_timer_absolute(timeout, callback)
add_timer(delay, callback)
shutdown()
new_connection(address, connect_timeout, socket_options, connection_closed_callback, message_callback, network_config)
class AsyncoreConnection(map, address, connect_timeout, socket_options, connection_closed_callback, message_callback, network_config, logger_extras=None)

Bases: hazelcast.connection.Connection, asyncore.dispatcher

sent_protocol_bytes = False
read_buffer_size = 128000
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)