Function createEmulatorInstance

e2e/src/emulator-instance.ts:55–71

(service: string, label = "e2e")

// and retry with backoff. Nothing below this line retries anything the
// scenario is actually asserting on.
export const createEmulatorInstance = (service: string, label = "e2e"): Effect.Effect<string> =>
  requestInstance(service, label).pipe(
    Effect.timeoutOrElse({
      duration: ATTEMPT_TIMEOUT,
      orElse: () =>
        Effect.fail(new EmulatorInstanceError(service, `no response in ${ATTEMPT_TIMEOUT}`)),
    }),
    Effect.retry(
      Schedule.both(
        Schedule.exponential("500 millis").pipe(Schedule.jittered),
        Schedule.recurs(RETRIES),
      ),
    ),
    // An emulator the suite cannot reach at all is a defect in the run, not a
    // product failure the scenario should be asked to model.
    Effect.orDie,
  );