Function replyPartition

packages/infra/src/ClusterCosmos.ts:116–116

(requestId: string)

const messageDocId = (envelope: Envelope.Encoded, primaryKey: string | null) =>
  cosmosId(primaryKey === null ? envelopeId(envelope) : `primary::${primaryKey}`)
const replyPartition = (requestId: string) => `reply::${requestId}`
const runnerDocId = (address: string) => cosmosId(`runner::${address}`)
const lockDocId = (shardId: string) => cosmosId(`lock::${shardId}`)
const tenMinutes = Duration.toMillis(Duration.minutes(10))