Invocation¶
-
class
Invocation(invocation_service, request, partition_id=-1, address=None, connection=None, event_handler=None)¶ Bases:
object-
sent_connection= None¶
-
timer= None¶
-
has_connection()¶
-
has_partition_id()¶
-
has_address()¶
-
set_response(response)¶
-
set_exception(exception, traceback=None)¶
-
set_timeout(timeout)¶
-
on_timeout()¶
-
-
class
InvocationService(client)¶ Bases:
object-
logger= <Logger HazelcastClient.InvocationService (WARNING)>¶
-
start()¶
-
invoke_on_connection(message, connection, ignore_heartbeat=False, event_handler=None)¶
-
invoke_on_partition(message, partition_id, invocation_timeout=None)¶
-
invoke_on_random_target(message)¶
-
invoke_on_target(message, address)¶
-
invoke_smart(invocation, ignore_heartbeat=False)¶
-
invoke_non_smart(invocation, ignore_heartbeat=False)¶
-
cleanup_connection(connection, cause)¶
-
on_connect(f, invocation, ignore_heartbeat)¶
-