Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 21 for dequeue (0.05 sec)

  1. fess-crawler-opensearch/src/main/resources/mapping/queue.json

    Shinsuke Sugaya <******@****.***> 1730954650 +0900
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 457 bytes
    - Viewed (0)
  2. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/util/OpenSearchCrawlerConfig.java

            this.filterIndex = filterIndex;
        }
    
        /**
         * Returns the number of queue shards.
         * @return The number of queue shards.
         */
        public int getQueueShards() {
            return queueShards;
        }
    
        /**
         * Sets the number of queue shards.
         * @param queueShards The number of queue shards.
         */
        public void setQueueShards(final int queueShards) {
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 5.4K bytes
    - Viewed (0)
  3. .github/workflows/team-triage-stale.yml

    name: 'Requeue stale team-triage items'
    on:
      schedule:
        # Execute every day at 00:05 to avoid conflicts with other workflows
        - cron: '5 0 * * *'
    
    permissions: {}
    
    jobs:
      requeue:
        permissions:
          issues: write
          pull-requests: write
        runs-on: ubuntu-latest
        steps:
          - uses: actions/stale@v10
            with:
              operations-per-run: 50
              remove-stale-when-updated: false
    
    Registered: Wed Sep 10 11:36:15 UTC 2025
    - Last Modified: Thu Sep 04 22:13:29 UTC 2025
    - 836 bytes
    - Viewed (0)
  4. fess-crawler/src/main/java/org/codelibs/fess/crawler/service/impl/UrlQueueServiceImpl.java

     * This class provides methods for managing a queue of URLs to be crawled,
     * including adding, deleting, and retrieving URLs from the queue.
     * It uses a {@link MemoryDataHelper} to store the URL queue data in memory.
     *
     * <p>
     * The class is responsible for:
     * </p>
     * <ul>
     *   <li>Updating session IDs for URL queues.</li>
     *   <li>Adding new URLs to the queue.</li>
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 9.3K bytes
    - Viewed (0)
  5. fess-crawler/src/main/java/org/codelibs/fess/crawler/helper/MemoryDataHelper.java

            sessionMap.clear();
        }
    
        /**
         * Returns the URL queue for the specified session ID.
         * Creates a new queue if one doesn't exist.
         * @param sessionId the session ID
         * @return the URL queue for the session
         */
        public synchronized Queue<UrlQueueImpl<Long>> getUrlQueueList(final String sessionId) {
            Queue<UrlQueueImpl<Long>> urlQueueList = urlQueueMap.get(sessionId);
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  6. fess-crawler/src/main/java/org/codelibs/fess/crawler/util/CrawlingParameterUtil.java

            return URL_QUEUE_THREAD_LOCAL.get();
        }
    
        /**
         * Sets the URL queue for the current thread. If the provided URL queue is null,
         * the URL queue for the current thread is removed.
         *
         * @param urlQueue the URL queue to be set for the current thread, or null to remove the URL queue
         */
        public static void setUrlQueue(final UrlQueue<?> urlQueue) {
            if (urlQueue == null) {
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Mar 15 06:52:00 UTC 2025
    - 6.4K bytes
    - Viewed (0)
  7. fess-crawler/src/main/java/org/codelibs/fess/crawler/entity/UrlQueue.java

    /**
     * The UrlQueue interface represents a queue of URLs to be processed by a web crawler.
     * It provides methods to get and set various properties of a URL queue entry.
     *
     * @param <IDTYPE> the type of the identifier for the URL queue entry
     */
    public interface UrlQueue<IDTYPE> {
    
        /**
         * Retrieves the unique identifier of the URL queue.
         *
         * @return the unique identifier of type IDTYPE.
         */
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Mar 15 06:52:00 UTC 2025
    - 4.3K bytes
    - Viewed (0)
  8. fess-crawler/src/main/java/org/codelibs/fess/crawler/service/UrlQueueService.java

        /**
         * Adds a URL to the queue.
         *
         * @param sessionId The session ID.
         * @param url The URL.
         */
        void add(String sessionId, String url);
    
        /**
         * Inserts a URL queue.
         *
         * @param urlQueue The URL queue.
         */
        void insert(QUEUE urlQueue);
    
        /**
         * Deletes a URL queue.
         *
         * @param sessionId The session ID.
         */
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 2.6K bytes
    - Viewed (0)
  9. fess-crawler/src/main/java/org/codelibs/fess/crawler/interval/impl/AbstractIntervalController.java

     *   <li>Before processing a URL ({@link #delayBeforeProcessing()})</li>
     *   <li>After processing a URL ({@link #delayAfterProcessing()})</li>
     *   <li>When there are no URLs in the queue ({@link #delayAtNoUrlInQueue()})</li>
     *   <li>While waiting for new URLs to be added to the queue ({@link #delayForWaitingNewUrl()})</li>
     * </ul>
     *
     * <p>
     * Subclasses are responsible for implementing the abstract methods to define the actual delay
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 4.5K bytes
    - Viewed (0)
  10. fess-crawler/src/main/java/org/codelibs/fess/crawler/entity/UrlQueueImpl.java

        /** The metadata associated with the URL queue. */
        protected String metaData;
    
        /** The encoding of the URL queue. */
        protected String encoding;
    
        /** The parent URL of the current URL in the queue. */
        protected String parentUrl;
    
        /** The depth of the URL in the queue. */
        protected Integer depth;
    
        /** The last modified timestamp of the URL in the queue. */
        protected Long lastModified;
    
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 6.1K bytes
    - Viewed (0)
Back to top