Base

class Proxy(service_name: str, name: str, context)[source]

Bases: Generic[BlockingProxyType], ABC

Provides basic functionality for Hazelcast Proxies.

destroy() → bool[source]

Destroys this proxy.

Returns:: True if this proxy is destroyed successfully, False otherwise.

abstract blocking() → BlockingProxyType[source]: Returns a version of this proxy with only blocking method calls.

class PartitionSpecificProxy(service_name, name, context)[source]

Bases: Proxy[BlockingProxyType], ABC

Provides basic functionality for Partition Specific Proxies.

class TransactionalProxy(name, transaction, context)[source]

Bases: object

Provides an interface for all transactional distributed objects.

class ItemEventType[source]

Bases: object

Type of item events.

ADDED = 1: Fired when an item is added.

REMOVED = 2: Fired when an item is removed.

class EntryEventType[source]

Bases: object

Type of entry event.

ADDED = 1: Fired if an entry is added.

REMOVED = 2: Fired if an entry is removed.

UPDATED = 4: Fired if an entry is updated.

EVICTED = 8: Fired if an entry is evicted.

EXPIRED = 16: Fired if an entry is expired.

EVICT_ALL = 32: Fired if all entries are evicted.

CLEAR_ALL = 64: Fired if all entries are cleared.

MERGED = 128: Fired if an entry is merged after a network partition.

INVALIDATION = 256: Fired if an entry is invalidated.

LOADED = 512: Fired if an entry is loaded.

class ItemEvent(name: str, item: ItemEventType, event_type: int, member: MemberInfo)[source]

Bases: Generic[ItemType]

Map Item event.

name: Name of the proxy that fired the event.

item: The item related to the event.

event_type: Type of the event.

member: Member that fired the event.

class EntryEvent(key: KeyType, value: ValueType, old_value: ValueType, merging_value: ValueType, event_type: int, member_uuid: UUID, number_of_affected_entries: int)[source]

Bases: Generic[KeyType, ValueType]

Map Entry event.

event_type: Type of the event.

uuid: UUID of the member that fired the event.

number_of_affected_entries: Number of affected entries by this event.

key: The key of this entry event.

value: The value of the entry event.

old_value: The old value of the entry event.

merging_value: The incoming merging value of the entry event.

class TopicMessage(name: str, message: MessageType, publish_time: int, member: MemberInfo | None)[source]

Bases: Generic[MessageType]

Topic message.

name: Name of the proxy that fired the event.

message: The message sent to Topic.

publish_time: UNIX time that the event is published as seconds.

member: Member that fired the event.