Package com.floragunn.searchsupport.jobs

Class SchedulerBuilder<JobType extends JobConfig>

java.lang.Object

com.floragunn.searchsupport.jobs.SchedulerBuilder<JobType>

public class SchedulerBuilder<JobType extends JobConfig>
extends Object

Constructor Summary

Constructors

Constructor	Description
SchedulerBuilder()

Method Summary

Modifier and Type	Method	Description
org.quartz.Scheduler	build()
SchedulerBuilder<JobType>	client(org.elasticsearch.client.Client client)
SchedulerBuilder<JobType>	configIndex(String configIndex)
SchedulerBuilder<JobType>	configIndex(String configIndex, org.elasticsearch.index.query.QueryBuilder configIndexQuery)
SchedulerBuilder<JobType>	distributed(org.elasticsearch.cluster.service.ClusterService clusterService, org.elasticsearch.env.NodeEnvironment nodeEnvironment)
SchedulerBuilder<JobType>	jobConfigFactory(JobConfigFactory<JobType> jobFactory)
SchedulerBuilder<JobType>	jobConfigListener(JobConfigListener<JobType> jobConfigListener)
SchedulerBuilder<JobType>	jobConfigSource(Iterable<JobType> jobConfigSource)
SchedulerBuilder<JobType>	jobFactory(org.quartz.spi.JobFactory jobFactory)
SchedulerBuilder<JobType>	jobStore(org.quartz.spi.JobStore jobStore)
SchedulerBuilder<JobType>	maxThreads(int maxThreads)
SchedulerBuilder<JobType>	name(String name)
SchedulerBuilder<JobType>	nodeComparator(NodeComparator<?> nodeComparator)
SchedulerBuilder<JobType>	nodeFilter(String nodeFilter)
SchedulerBuilder<JobType>	stateIndex(String stateIndex)
SchedulerBuilder<JobType>	stateIndexIdPrefix(String stateIndexIdPrefix)
SchedulerBuilder<JobType>	threadKeepAlive(Duration threadKeepAlive)
SchedulerBuilder<JobType>	threadPool(org.quartz.spi.ThreadPool threadPool)
SchedulerBuilder<JobType>	threadPriority(int threadPriority)

Methods inherited from class java.lang.Object

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

Constructor Detail

SchedulerBuilder

public SchedulerBuilder()

Method Detail

name

public SchedulerBuilder<JobType> name(String name)

configIndex

public SchedulerBuilder<JobType> configIndex(String configIndex)

configIndex

public SchedulerBuilder<JobType> configIndex(String configIndex,
                                             org.elasticsearch.index.query.QueryBuilder configIndexQuery)

stateIndex

public SchedulerBuilder<JobType> stateIndex(String stateIndex)

stateIndexIdPrefix

public SchedulerBuilder<JobType> stateIndexIdPrefix(String stateIndexIdPrefix)

distributed

public SchedulerBuilder<JobType> distributed(org.elasticsearch.cluster.service.ClusterService clusterService,
                                             org.elasticsearch.env.NodeEnvironment nodeEnvironment)

nodeFilter

public SchedulerBuilder<JobType> nodeFilter(String nodeFilter)

client

public SchedulerBuilder<JobType> client(org.elasticsearch.client.Client client)

maxThreads

public SchedulerBuilder<JobType> maxThreads(int maxThreads)

threadPriority

public SchedulerBuilder<JobType> threadPriority(int threadPriority)

threadKeepAlive

public SchedulerBuilder<JobType> threadKeepAlive(Duration threadKeepAlive)

jobConfigFactory

public SchedulerBuilder<JobType> jobConfigFactory(JobConfigFactory<JobType> jobFactory)

jobFactory

public SchedulerBuilder<JobType> jobFactory(org.quartz.spi.JobFactory jobFactory)

jobConfigSource

public SchedulerBuilder<JobType> jobConfigSource(Iterable<JobType> jobConfigSource)

jobStore

public SchedulerBuilder<JobType> jobStore(org.quartz.spi.JobStore jobStore)

threadPool

public SchedulerBuilder<JobType> threadPool(org.quartz.spi.ThreadPool threadPool)

nodeComparator

public SchedulerBuilder<JobType> nodeComparator(NodeComparator<?> nodeComparator)

jobConfigListener

public SchedulerBuilder<JobType> jobConfigListener(JobConfigListener<JobType> jobConfigListener)

build

public org.quartz.Scheduler build()
                           throws org.quartz.SchedulerException

Throws:

org.quartz.SchedulerException