sharding

fun sharding(aggregateId: AggregateId): ConnectionFactory