com.atlassian.bamboo.index.buildresult

Class DefaultBuildResultsIndexer

java.lang.Object

com.atlassian.bamboo.index.AbstractIndexer

com.atlassian.bamboo.index.buildresult.DefaultBuildResultsIndexer

All Implemented Interfaces:

BuildResultsIndexer, Indexer

public class DefaultBuildResultsIndexer
extends AbstractIndexer
implements BuildResultsIndexer

Nested Class Summary

Nested classes/interfaces inherited from class com.atlassian.bamboo.index.AbstractIndexer

AbstractIndexer.FlushAndUnlockIndexerQueueCallback, AbstractIndexer.IndexAllCallable, AbstractIndexer.UpdateApproximateIndexingTimePerResultCallback

Field Summary

Fields inherited from class com.atlassian.bamboo.index.AbstractIndexer

indexerService, luceneConnection

Constructor Summary

Constructors

Constructor and Description

DefaultBuildResultsIndexer(com.atlassian.bonnie.ILuceneConnection luceneConnection, com.atlassian.bandana.BandanaManager bandanaManager, com.atlassian.config.db.HibernateConfig hibernateConfig, IndexerService indexerService, BuildResultsSummaryDao buildResultsSummaryDao, BuildResultsSummaryDocumentFactory buildResultsSummaryDocumentFactory, CachedPlanManager cachedPlanManager, com.atlassian.event.api.EventPublisher eventPublisher)

Method Summary

Modifier and Type	Method and Description
void	deIndexBuild(PlanKey planKey)
void	deIndexBuild(PlanKey planKey, Set<String> affectedJiraIssuesKeys)
void	deIndexBuildResults(ResultsSummary summary, boolean includeTests)
void	deIndexChainResults(ChainResultsSummary summary, Set<String> affectedJiraIssuesKeys, boolean includeTests) Deprecated. since 5.5
long	getEstimatedReindexTime() How long will it take to reindex all objects in this index.
protected BambooBandanaContext	getIndexerBandanaContext()
void	indexAll(Executor executor) Build result reindex splits workload creating tasks for every plan/job
long	indexChain(ImmutableChain plan) Indexes the build.
long	indexJob(ImmutableChain immutableChain, PlanKey jobKey) Indexes the job.
long	indexJob(ImmutableJob plan) Indexes the build.
void	indexResultSummary(ResultsSummary summary, ImmutableChain chain, ImmutablePlan plan) Schedules indexing of result summary
void	reIndexBuildResults(ResultsSummary summary, ImmutableChain chain, ImmutablePlan plan, boolean includeTests)
void	reIndexBuildResults(ResultsSummary summary, ImmutableChain chain, ImmutablePlan plan, Set<String> affectedJiraIssuesKeys, boolean includeTests)
protected void	updateApproximateIndexingTimePerResult(long totalIndexingTime, int entityCount)

Methods inherited from class com.atlassian.bamboo.index.AbstractIndexer

deleteIndex, flushAndUnlockIndexerQueue, getApproximateIndexingTimePerResult, getConcurrentIndexers, getDefaultIndexerContext, getNumberOfDocuments, lockIndexerQueue

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.atlassian.bamboo.index.Indexer

deleteIndex, getNumberOfDocuments

Constructor Detail

DefaultBuildResultsIndexer

public DefaultBuildResultsIndexer(com.atlassian.bonnie.ILuceneConnection luceneConnection,
                                  com.atlassian.bandana.BandanaManager bandanaManager,
                                  com.atlassian.config.db.HibernateConfig hibernateConfig,
                                  IndexerService indexerService,
                                  BuildResultsSummaryDao buildResultsSummaryDao,
                                  BuildResultsSummaryDocumentFactory buildResultsSummaryDocumentFactory,
                                  CachedPlanManager cachedPlanManager,
                                  com.atlassian.event.api.EventPublisher eventPublisher)

Method Detail

indexAll

public void indexAll(@NotNull
                     Executor executor)
              throws Exception

Build result reindex splits workload creating tasks for every plan/job

Specified by:

indexAll in interface Indexer

Parameters:

executor - allows multithreaded execution of indexer

Throws:

Exception

indexChain

public long indexChain(ImmutableChain plan)

Description copied from interface: BuildResultsIndexer

Indexes the build.

Specified by:

indexChain in interface BuildResultsIndexer

Returns:

number of millis this index operation took

indexJob

public long indexJob(ImmutableJob plan)

Description copied from interface: BuildResultsIndexer

Indexes the build.

Specified by:

indexJob in interface BuildResultsIndexer

Returns:

number of millis this index operation took

indexJob

public long indexJob(ImmutableChain immutableChain,
                     PlanKey jobKey)

Description copied from interface: BuildResultsIndexer

Indexes the job.

Specified by:

indexJob in interface BuildResultsIndexer

Parameters:

immutableChain - chain that job belongs to

jobKey - jobKey (does not need to exist in DB)

Returns:

number of millis this index operation took

indexResultSummary

public void indexResultSummary(@NotNull
                               ResultsSummary summary,
                               @NotNull
                               ImmutableChain chain,
                               @Nullable
                               ImmutablePlan plan)

Description copied from interface: BuildResultsIndexer

Schedules indexing of result summary

Specified by:

indexResultSummary in interface BuildResultsIndexer

Parameters:

summary - ResultsSummary to be indexed

plan - Plan this summary belongs to

reIndexBuildResults

public void reIndexBuildResults(@NotNull
                                ResultsSummary summary,
                                @NotNull
                                ImmutableChain chain,
                                @Nullable
                                ImmutablePlan plan,
                                @Nullable
                                Set<String> affectedJiraIssuesKeys,
                                boolean includeTests)
                         throws Exception

Specified by:

reIndexBuildResults in interface BuildResultsIndexer

Throws:

Exception

reIndexBuildResults

public void reIndexBuildResults(@NotNull
                                ResultsSummary summary,
                                @NotNull
                                ImmutableChain chain,
                                @Nullable
                                ImmutablePlan plan,
                                boolean includeTests)
                         throws Exception

Specified by:

reIndexBuildResults in interface BuildResultsIndexer

Throws:

Exception

deIndexBuild

public void deIndexBuild(@NotNull
                         PlanKey planKey)
                  throws Exception

Specified by:

deIndexBuild in interface BuildResultsIndexer

Throws:

Exception

deIndexBuild

public void deIndexBuild(@NotNull
                         PlanKey planKey,
                         @NotNull
                         Set<String> affectedJiraIssuesKeys)
                  throws Exception

Specified by:

deIndexBuild in interface BuildResultsIndexer

Throws:

Exception

deIndexBuildResults

public void deIndexBuildResults(ResultsSummary summary,
                                boolean includeTests)

Specified by:

deIndexBuildResults in interface BuildResultsIndexer

deIndexChainResults

@Deprecated
public void deIndexChainResults(@NotNull
                                            ChainResultsSummary summary,
                                            Set<String> affectedJiraIssuesKeys,
                                            boolean includeTests)

Deprecated. since 5.5

Specified by:

deIndexChainResults in interface BuildResultsIndexer

getEstimatedReindexTime

public long getEstimatedReindexTime()

Description copied from interface: Indexer

How long will it take to reindex all objects in this index.

Specified by:

getEstimatedReindexTime in interface Indexer

Returns:

seconds of how long

getIndexerBandanaContext

protected BambooBandanaContext getIndexerBandanaContext()

Specified by:

getIndexerBandanaContext in class AbstractIndexer

updateApproximateIndexingTimePerResult

protected void updateApproximateIndexingTimePerResult(long totalIndexingTime,
                                                      int entityCount)

Overrides:

updateApproximateIndexingTimePerResult in class AbstractIndexer