Package ai.platon.pulsar.skeleton.crawl.impl

Class AbstractTaskRunner

  • All Implemented Interfaces:
    ai.platon.pulsar.common.event.EventEmitter , ai.platon.pulsar.skeleton.crawl.TaskRunner , java.lang.AutoCloseable 
    
public abstract class AbstractTaskRunner
extends AbstractEventEmitter<CrawlEvents> implements TaskRunner

    • Nested Class Summary

      Nested Classes 
      Modifier and Type Class Description

    • Enum Constant Summary

      Enum Constants 
      Enum Constant Description

    • Method Summary

      Modifier and Type Method Description
      Integer getId() The crawl id
      String getName() The crawl name
      Function2<Integer, UrlAware, Duration> getRetryDelayPolicy() Delay policy for retry tasks
      Unit setRetryDelayPolicy(Function2<Integer, UrlAware, Duration> retryDelayPolicy) Delay policy for retry tasks
      Boolean isActive()
      final PulsarSession getSession()
      final Boolean getAutoClose()
      Unit pause()
      Unit resume()
      Unit report()
      Unit onWillLoad(UrlAware url)
      Unit onLoad(UrlAware url)
      Unit onLoaded(UrlAware url, WebPage page)
      Unit close()

      • Methods inherited from class ai.platon.pulsar.common.event.AbstractEventEmitter

        count, emit, emit, emit, emit, emit1, emit1, emit1, emit1, getEventExceptionHandler, getListeners, hasListeners, listeners, listeners, off, off, off, off, off, off1, off1, off1, off1, off1, on, on, on, on, on1, on1, on1, on1, once, once, once, once1, once1, once1, setEventExceptionHandler

      • Methods inherited from class ai.platon.pulsar.skeleton.crawl.TaskRunner

        await

      • Methods inherited from class ai.platon.pulsar.common.event.EventEmitter

        hasNormalListeners, hasSuspendListeners, normalListeners, normalListeners, suspendListeners, suspendListeners

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait