Function messageDocId

packages/infra/src/ClusterCosmos.ts:114–115

(envelope: Envelope.Encoded, primaryKey: string | null)

const cosmosId = (id: string) => encodeURIComponent(id)
const messagePartition = (shardId: string) => `message::${shardId}`
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}`)