Function tryAcquire

packages/infra/src/ClusterCosmos.ts:920–936

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

      )

  const tryAcquire = (address: string, shardId: string, now: number) =>
    readLock(shardId).pipe(
      Effect.flatMap((lock) =>
        Option.match(lock, {
          onNone: () => createLock(address, shardId, now),
          onSome: (doc) => {
            if (doc.address !== address && now - doc.acquiredAt <= expires) {
              return Effect.succeed(false)
            }
            doc.address = address
            doc.acquiredAt = now
            return writeLock(doc)
          }
        })
      ),
      Effect.map((acquired) => acquired ? Option.some(shardId) : Option.none())
    )

  return RunnerStorage.makeEncoded({
    getRunners: Effect.sync(() => Date.now()).pipe(