Method shardFiles

packages/utils/src/lib/wal-sharded.ts:325–340

Get all shard file paths matching this WAL's base name

()

  /** Get all shard file paths matching this WAL's base name */
  private shardFiles() {
    if (!fs.existsSync(this.#dir)) {
      return [];
    }

    const groupDir = path.join(this.#dir, this.groupId);
    if (!fs.existsSync(groupDir)) {
      return [];
    }

    return fs
      .readdirSync(groupDir)
      .filter(entry => entry.endsWith(this.#format.walExtension))
      .filter(entry => entry.startsWith(`${this.#format.baseName}`))
      .map(entry => path.join(groupDir, entry));
  }

  /** Get shard file paths created by this instance */
  private getCreatedShardFiles() {