Struct PlacementShardingAdapter 

pub struct PlacementShardingAdapter { /* private fields */ }

Adapter that publishes a [ShardRegion<DeviceExtractor>] backed by a fixed pool of pre-spawned DeviceActor refs. Each shard maps to one device via shard_index % devices.len(), so identical entity_ids always reach the same device.

Implementations

impl PlacementShardingAdapter

pub fn start( region_id: impl Into<String>, devices: Vec<ActorRef<DeviceMsg>>, shard_count: usize, ) -> Self

Build the adapter from a fleet of device refs. region_id is the cluster-visible name of this region (mirrors akka.net’s type-name parameter to ClusterSharding.Start(...)).

shard_count controls the routing granularity; larger values distribute consecutive entity ids more evenly. Defaults to the number of devices when zero.

pub fn entity(&self, entity_id: impl Into<String>) -> EntityRef<DeviceExtractor>

Build a typed handle to a particular entity.

pub fn region(&self) -> Arc<ShardRegion<DeviceExtractor>>

Direct access to the underlying [ShardRegion] — useful for installing a remote forwarder or inspecting shard counts.