Function entityAddressFor

packages/cluster/src/ClusterWorkflowEngine.ts:136–150

(options: {
    readonly workflow: Workflow.Any
    readonly entityType: string
    readonly executionId: string
  })

    idleTimeToLive: "5 minutes"
  })
  const entityAddressFor = (options: {
    readonly workflow: Workflow.Any
    readonly entityType: string
    readonly executionId: string
  }) => {
    const shardGroup = Context.get(options.workflow.annotations, ClusterSchema.ShardGroup)(
      options.executionId as EntityId
    )
    const entityId = EntityId.make(options.executionId)
    return new EntityAddress({
      entityType: EntityType.make(options.entityType),
      entityId,
      shardId: sharding.getShardId(entityId, shardGroup)
    })
  }

  const sendDiscard = Effect.fnUntraced(function*(options: {
    readonly rpc: Rpc.AnyWithProps