Package jetbrains.buildServer.serverSide.build.index

Class BuildPTRIndexer

java.lang.Object

jetbrains.buildServer.serverSide.build.index.BuildPTRIndexer

All Implemented Interfaces:

BuildIndexer

public class BuildPTRIndexer
extends Object
implements BuildIndexer

Field Summary

Fields

Modifier and Type	Field	Description
static ThreadLocal<PriorityThreadPoolExecutor>	CURRENT_THREAD_EXECUTOR
static byte	PRIORITY_HIGH
static byte	PRIORITY_NORMAL

Constructor Summary

Constructors

Constructor	Description
BuildPTRIndexer(Supplier<Result<? extends BuildIndex>> indexSupplier, BuildIndexerOptions options, BuildsManager buildsManager, SQLRunnerEx sqlRunner, ExecutorServices executorServices, ServerMetrics serverMetrics)

Method Summary

Modifier and Type	Method	Description
Future<?>	addBuild(long buildId)
void	configurationUpdate()
List<Future<?>>	deleteBuilds(Collection<BuildIdAndTimestamp> buildIds)
gnu.trove.list.array.TLongArrayList	getHistoryBuildId(Long topBuildId, int size)
Optional<BuildIndex>	getIndex()
BuildIndexerStat	getStatistic()
IndexStatus	getStatus()
boolean	isActive()
boolean	isAlive()
void	pause()
Future<?>	reindexBuild(long buildId, byte priority, ReindexBuildPolicy reindexPolicy)
Future<?>	reindexBuild(long buildId, ReindexBuildPolicy reindexPolicy)
Future<List<Future<?>>>	reset()	Complete index cleanup / history run.
Future<List<Future<?>>>	restart()
void	resume()
static void	shutdownNowAndWait(PriorityThreadPoolExecutor executor, String indexName)
Future<?>	start()
void	stop()
Future<List<Future<?>>>	sync()

Methods inherited from class java.lang.Object

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

Field Detail

CURRENT_THREAD_EXECUTOR

public static final ThreadLocal<PriorityThreadPoolExecutor> CURRENT_THREAD_EXECUTOR

PRIORITY_HIGH

public static final byte PRIORITY_HIGH

See Also:

Constant Field Values

PRIORITY_NORMAL

public static final byte PRIORITY_NORMAL

See Also:

Constant Field Values

Constructor Detail

BuildPTRIndexer

public BuildPTRIndexer(@NotNull
                       Supplier<Result<? extends BuildIndex>> indexSupplier,
                       @NotNull
                       BuildIndexerOptions options,
                       @NotNull
                       BuildsManager buildsManager,
                       @NotNull
                       SQLRunnerEx sqlRunner,
                       @NotNull
                       ExecutorServices executorServices,
                       @NotNull
                       ServerMetrics serverMetrics)

Method Detail

isActive

public boolean isActive()

isAlive

public boolean isAlive()

Specified by:

isAlive in interface BuildIndexer

pause

public void pause()

Specified by:

pause in interface BuildIndexer

resume

public void resume()

Specified by:

resume in interface BuildIndexer

getStatistic

public BuildIndexerStat getStatistic()

Specified by:

getStatistic in interface BuildIndexer

getIndex

@NotNull
public Optional<BuildIndex> getIndex()

Specified by:

getIndex in interface BuildIndexer

getStatus

public IndexStatus getStatus()

Specified by:

getStatus in interface BuildIndexer

start

public Future<?> start()

Specified by:

start in interface BuildIndexer

configurationUpdate

public void configurationUpdate()

Specified by:

configurationUpdate in interface BuildIndexer

restart

public Future<List<Future<?>>> restart()

Specified by:

restart in interface BuildIndexer

sync

public Future<List<Future<?>>> sync()

Specified by:

sync in interface BuildIndexer

reset

public Future<List<Future<?>>> reset()

Description copied from interface: BuildIndexer

Complete index cleanup / history run.

Specified by:

reset in interface BuildIndexer

Returns:

stop

public void stop()

Specified by:

stop in interface BuildIndexer

shutdownNowAndWait

public static void shutdownNowAndWait(PriorityThreadPoolExecutor executor,
                                      String indexName)

addBuild

public Future<?> addBuild(long buildId)

Specified by:

addBuild in interface BuildIndexer

deleteBuilds

public List<Future<?>> deleteBuilds(@NotNull
                                    Collection<BuildIdAndTimestamp> buildIds)

Specified by:

deleteBuilds in interface BuildIndexer

reindexBuild

public Future<?> reindexBuild(long buildId,
                              @NotNull
                              ReindexBuildPolicy reindexPolicy)

Specified by:

reindexBuild in interface BuildIndexer

reindexBuild

public Future<?> reindexBuild(long buildId,
                              byte priority,
                              @NotNull
                              ReindexBuildPolicy reindexPolicy)

getHistoryBuildId

public gnu.trove.list.array.TLongArrayList getHistoryBuildId(Long topBuildId,
                                                             int size)