Function createLock

packages/infra/src/ClusterCosmos.ts:902–918

(address: string, shardId: string, now: number)

      )

  const createLock = (address: string, shardId: string, now: number) =>
    Effect
      .tryPromise(() =>
        container.items.create<LockDoc>({
          id: lockDocId(shardId),
          _partitionKey: "lock",
          type: "lock",
          shardId,
          address,
          acquiredAt: now
        })
      )
      .pipe(
        Effect.tap(annotateItem),
        Effect.as(true),
        Effect.catchIf(isConflict, () => Effect.succeed(false))
      )

  const tryAcquire = (address: string, shardId: string, now: number) =>
    readLock(shardId).pipe(