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)