Function messagePartition

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

(shardId: string)

const refailPersistence = <A, E, R>(effect: Effect.Effect<A, E, R>) => PersistenceError.refail(effect)
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}`