Method initialize

apps/coordinator/src/index.ts:128–181

()

  constructor(private opts = { forceSimulate: false }) {}

  async initialize(): Promise<CheckpointerInitializeReturn> {
    if (this.#initialized) {
      return this.#getInitializeReturn();
    }

    this.#logger.log(`${this.#dockerMode ? "Docker" : "Kubernetes"} mode`);

    if (this.#dockerMode) {
      try {
        await $`criu --version`;
      } catch (error) {
        this.#logger.error("No checkpoint support: Missing CRIU binary");
        this.#logger.error("Will simulate instead");
        this.#canCheckpoint = false;
        this.#initialized = true;

        return this.#getInitializeReturn();
      }

      try {
        await $`docker checkpoint`;
      } catch (error) {
        this.#logger.error(
          "No checkpoint support: Docker needs to have experimental features enabled"
        );
        this.#logger.error("Will simulate instead");
        this.#canCheckpoint = false;
        this.#initialized = true;

        return this.#getInitializeReturn();
      }
    } else {
      try {
        await $`buildah login --get-login ${REGISTRY_HOST}`;
      } catch (error) {
        this.#logger.error(`No checkpoint support: Not logged in to registry ${REGISTRY_HOST}`);
        this.#canCheckpoint = false;
        this.#initialized = true;

        return this.#getInitializeReturn();
      }
    }

    this.#logger.log(
      `Full checkpoint support${
        this.#dockerMode && this.opts.forceSimulate ? " with forced simulation enabled." : "!"
      }`
    );

    this.#initialized = true;
    this.#canCheckpoint = true;

    return this.#getInitializeReturn();
  }

  #getInitializeReturn(): CheckpointerInitializeReturn {
    return {