All Implemented Interfaces:: ai.platon.pulsar.common.event.EventEmitter , ai.platon.pulsar.crawl.Crawler , java.lang.AutoCloseable


public abstract class AbstractCrawler
extends AbstractEventEmitter<CrawlEvents> implements Crawler

Nested Class Summary

Nested Classes
Modifier and Type	Class	Description
`public class`	`AbstractCrawler.Companion`

Field Summary

Fields
Modifier and Type	Field	Description
`private final Integer`	`id`
`private final String`	`name`
`private Function2<Integer, UrlAware, Duration>`	`retryDelayPolicy`
`private final AtomicBoolean`	`closed`
`private final Boolean`	`isActive`
`private final PulsarSession`	`session`
`private final Boolean`	`autoClose`
`private final Map<CrawlEvents, List<Function<Object>>>`	`listeners`

Constructor Summary

Constructors
Constructor	Description
`AbstractCrawler(PulsarSession session, Boolean autoClose)`

Method Summary

Modifier and Type	Method	Description
`Integer`	`getId()`	The crawl id
`String`	`getName()`
`Function2<Integer, UrlAware, Duration>`	`getRetryDelayPolicy()`	Delay policy for retry tasks
`Unit`	`setRetryDelayPolicy(Function2<Integer, UrlAware, Duration> retryDelayPolicy)`	Delay policy for retry tasks
`final AtomicBoolean`	`getClosed()`
`Boolean`	`getIsActive()`
`final PulsarSession`	`getSession()`
`final Boolean`	`getAutoClose()`
`final Map<CrawlEvents, List<Function<Object>>>`	`getListeners()`
`Unit`	`onWillLoad(UrlAware url)`
`Unit`	`onLoad(UrlAware url)`
`Unit`	`onLoaded(UrlAware url, WebPage page)`
`Unit`	`close()`

Methods inherited from class ai.platon.pulsar.crawl.impl.AbstractCrawler
await, count, emit, emit, emit, emit, emit1, emit1, emit1, emit1, 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
Methods inherited from class ai.platon.pulsar.common.event.AbstractEventEmitter
hasNormalListeners, hasSuspendListeners, normalListeners, normalListeners, suspendListeners, suspendListeners
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AbstractCrawler

AbstractCrawler(PulsarSession session, Boolean autoClose)

Method Detail

getId
```
 Integer getId()
```
The crawl id

getName
```
 String getName()
```

getRetryDelayPolicy

 Function2<Integer, UrlAware, Duration> getRetryDelayPolicy()

Delay policy for retry tasks

setRetryDelayPolicy

 Unit setRetryDelayPolicy(Function2<Integer, UrlAware, Duration> retryDelayPolicy)

Delay policy for retry tasks

getClosed
```
 final AtomicBoolean getClosed()
```

getIsActive
```
 Boolean getIsActive()
```

getSession
```
 final PulsarSession getSession()
```

getAutoClose
```
 final Boolean getAutoClose()
```

getListeners

 final Map<CrawlEvents, List<Function<Object>>> getListeners()

onWillLoad
```
 Unit onWillLoad(UrlAware url)
```

onLoad
```
 Unit onLoad(UrlAware url)
```

onLoaded

 Unit onLoaded(UrlAware url, WebPage page)

close
```
 Unit close()
```

Class AbstractCrawler

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

Methods inherited from class ai.platon.pulsar.crawl.impl.AbstractCrawler

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

Methods inherited from class java.lang.Object

Constructor Detail

AbstractCrawler

Method Detail

getId

getName

getRetryDelayPolicy

setRetryDelayPolicy

getClosed

getIsActive

getSession

getAutoClose

getListeners

onWillLoad

onLoad

onLoaded

close