directoryLeaseManager.requestDirectoryLease(directoryPath, DirectoryLeaseState.DIRECTORY_READ_HANDLE,
                DirectoryCacheScope.IMMEDIATE_CHILDREN);

        // No cached listing initially
        assertNull(directoryLeaseManager.getCachedDirectoryListing(directoryPath));

        // Setup mock files
        when(mockFile1.getName()).thenReturn("file1.txt");

	objCh := minioClient.ListObjects(context.Background(), bucketToList, minio.ListObjectsOptions{})
	for obj := range objCh {
		if obj.Err != nil {
			log.Fatalf("Listing error: %v", obj.Err)
		}
		fmt.Printf("Key: %s\nSize: %d\nLast Modified: %s\n===\n", obj.Key, obj.Size, obj.LastModified)
	}

	objCh := minioClient.ListObjects(context.Background(), bucketToList, minio.ListObjectsOptions{})
	for obj := range objCh {
		if obj.Err != nil {
			log.Fatalf("Listing error: %v", obj.Err)
		}
		fmt.Printf("Key: %s\nSize: %d\nLast Modified: %s\n===\n", obj.Key, obj.Size, obj.LastModified)
	}

			last := objects[len(objects)-1]
			loi.NextMarker = last.Name
		}

		if loi.IsTruncated && merged.lastSkippedEntry > loi.NextMarker {
			// An object hidden by ILM was found during a truncated listing. Set the next marker
			// as the last skipped entry if it is lexically higher loi.NextMarker as an optimization
			loi.NextMarker = merged.lastSkippedEntry
		}

		if loi.NextMarker != "" {

            cb.query().addOrderBy_DuplicateHostName_Asc();
            cb.fetchFirst(fessConfig.getPageDuplicateHostMaxFetchSizeAsInteger());
        });
    }

    /**
     * Sets up the search conditions for listing duplicate host configurations.
     *
     * <p>This method configures the condition bean with search criteria from the pager,
     * including regular name wildcards and duplicate hostname wildcards.

import org.dbflute.optional.OptionalEntity;

import jakarta.annotation.Resource;

/**
 * Service class for managing web crawling configurations.
 * Provides CRUD operations for web configuration settings including
 * listing, retrieving, storing, and deleting web crawling configurations.
 */
public class WebConfigService extends FessAppService {

    /**
     * Default constructor.
     */
    public WebConfigService() {

			cache.error = err.Error()
			cache.status = scanStateError
			rpc.UpdateMetacacheListing(ctx, cache)
			return err
		}
		return nil
	}
	if cache.error != "" {
		return fmt.Errorf("async cache listing failed with: %s", cache.error)
	}
	return nil

import org.lastaflute.web.response.JsonResponse;
import org.lastaflute.web.response.StreamResponse;

/**
 * Handles API requests for storage management in the Fess application.
 * Provides endpoints for listing, downloading, deleting, and uploading files.
 */
public class ApiAdminStorageAction extends FessApiAdminAction {

    private static final Logger logger = LogManager.getLogger(ApiAdminStorageAction.class);

	scanStateSuccess
	scanStateError

	// Time in which the initiator of a scan must have reported back.
	metacacheMaxRunningAge = time.Minute

	// Max time between client calls before dropping an async cache listing.
	metacacheMaxClientWait = 3 * time.Minute

	// metacacheBlockSize is the number of file/directory entries to have in each block.
	metacacheBlockSize = 5000

/**
 * Service class for managing user operations in the Fess search system.
 * This service provides CRUD operations for user management, including user authentication,
 * password management, and user listing with pagination support.
 *
 */
public class UserService {

    /**
     * Default constructor for UserService.
     */
    public UserService() {
        // Default constructor
    }