Partition

class PartitionService(client)

Bases: object

An SPI service for accessing partition related information.

logger = <logging.Logger object>

timer = None

start()

Starts the partition service.

shutdown()

Shutdowns the partition service.

refresh()

Refreshes the partition service.

get_partition_owner(partition_id)

Gets the owner of the partition if it’s set. Otherwise it will trigger partition assignment.

Parameters:partition_id – (int), the partition id. Returns:(Address), owner of partition or None if it’s not set yet.

get_partition_id(key)

Returns the partition id for a Data key.

Parameters:key – (object), the data key. Returns:(int), the partition id.

get_partition_count()

Returns the number of partitions.

Returns:(int), the number of partitions.

process_partition_response(message)

string_partition_strategy(key)