(address: RunnerAddress)
| 229 | const getRegistrationEvents: Stream.Stream<ShardingRegistrationEvent> = Stream.fromPubSub(events) |
| 230 | |
| 231 | const isLocalRunner = (address: RunnerAddress) => |
| 232 | Option.isSome(config.runnerAddress) && Equal.equals(address, config.runnerAddress.value) |
| 233 | |
| 234 | function getShardId(entityId: EntityId, group: string): ShardId { |
| 235 | const id = Math.abs(hashString(entityId) % config.shardsPerGroup) + 1 |
no outgoing calls
no test coverage detected