Method constructor

packages/utils/src/lib/wal-sharded.ts:172–210

* Create a sharded WAL manager. * * @param opt.dir - Base directory to store shard files (defaults to process.cwd()) * @param opt.format - WAL format configuration * @param opt.groupId - Group ID for sharding (defaults to generated group ID) * @param opt.coordinatorIdEnvVar - Environm

(opt: {
    debug?: boolean;
    dir?: string;
    format: WalFormat<T>;
    groupId?: string;
    coordinatorIdEnvVar: string;
    autoCoordinator?: boolean;
  })

   * @param opt.autoCoordinator - Whether to auto-set the coordinator ID on construction (defaults to true)
   */
  constructor(opt: {
    debug?: boolean;
    dir?: string;
    format: WalFormat<T>;
    groupId?: string;
    coordinatorIdEnvVar: string;
    autoCoordinator?: boolean;
  }) {
    const {
      dir,
      format,
      debug,
      groupId,
      coordinatorIdEnvVar,
      autoCoordinator = true,
    } = opt;

    if (debug != null) {
      this.#debug = debug;
    }

    // Determine groupId: use provided, then env var, or generate
    const resolvedGroupId: string =
      groupId == null ? getUniqueTimeId() : groupId;
    // Validate groupId for path safety before using it
    validateGroupId(resolvedGroupId);

    this.groupId = resolvedGroupId;

    if (dir) {
      this.#dir = dir;
    }
    this.#format = format;
    this.#coordinatorIdEnvVar = coordinatorIdEnvVar;

    if (autoCoordinator) {
      ShardedWal.setCoordinatorProcess(this.#coordinatorIdEnvVar, this.#id);
    }
  }

  /**
   * Gets the unique instance ID for this ShardedWal.