Package org.apache.syncope.core.provisioning.java.job

Class OpenSearchReindex

java.lang.Object

org.apache.syncope.core.provisioning.java.job.AbstractSchedTaskJobDelegate<SchedTask>

org.apache.syncope.core.provisioning.java.job.OpenSearchReindex

All Implemented Interfaces:

SchedTaskJobDelegate

public class OpenSearchReindex
extends AbstractSchedTaskJobDelegate<SchedTask>

Remove and rebuild all OpenSearch indexes with information from existing users, groups and any objects.

Field Summary

Fields

Modifier and Type	Field	Description
protected AnyObjectDAO	anyObjectDAO
protected org.opensearch.client.opensearch.OpenSearchClient	client
protected GroupDAO	groupDAO
protected OpenSearchIndexManager	indexManager
protected RealmDAO	realmDAO
protected UserDAO	userDAO
protected OpenSearchUtils	utils

Fields inherited from class org.apache.syncope.core.provisioning.java.job.AbstractSchedTaskJobDelegate

auditManager, executor, LOG, manageOperationId, notificationManager, publisher, securityProperties, task, taskDAO, taskExecDAO, taskType, taskUtilsFactory

Constructor Summary

Constructors

Constructor	Description
OpenSearchReindex()

Method Summary

Modifier and Type	Method	Description
protected org.opensearch.client.opensearch._types.mapping.TypeMapping	anyObjectMapping()
protected org.opensearch.client.opensearch.indices.IndexSettings	anyObjectSettings()
protected org.opensearch.client.opensearch._types.mapping.TypeMapping	auditMapping()
protected org.opensearch.client.opensearch.indices.IndexSettings	auditSettings()
protected String	doExecute(JobExecutionContext context)	The actual execution, delegated to child classes.
protected org.opensearch.client.opensearch._types.mapping.TypeMapping	groupMapping()
protected org.opensearch.client.opensearch.indices.IndexSettings	groupSettings()
protected boolean	hasToBeRegistered(TaskExec<?> execution)	Template method to determine whether this job's task execution has to be persisted or not.
protected org.opensearch.client.opensearch._types.mapping.TypeMapping	realmMapping()
protected org.opensearch.client.opensearch.indices.IndexSettings	realmSettings()
protected org.opensearch.client.opensearch._types.mapping.TypeMapping	userMapping()
protected org.opensearch.client.opensearch.indices.IndexSettings	userSettings()

Methods inherited from class org.apache.syncope.core.provisioning.java.job.AbstractSchedTaskJobDelegate

end, endExecution, execute, init, initExecution, register, setStatus

Methods inherited from class java.lang.Object

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

Field Details

client

@Autowired
protected org.opensearch.client.opensearch.OpenSearchClient client

indexManager

@Autowired
protected OpenSearchIndexManager indexManager

utils

@Autowired
protected OpenSearchUtils utils

userDAO

@Autowired
protected UserDAO userDAO

groupDAO

@Autowired
protected GroupDAO groupDAO

anyObjectDAO

@Autowired
protected AnyObjectDAO anyObjectDAO

realmDAO

@Autowired
protected RealmDAO realmDAO

Constructor Details

OpenSearchReindex

public OpenSearchReindex()

Method Details

userSettings

protected org.opensearch.client.opensearch.indices.IndexSettings userSettings()

groupSettings

protected org.opensearch.client.opensearch.indices.IndexSettings groupSettings()

anyObjectSettings

protected org.opensearch.client.opensearch.indices.IndexSettings anyObjectSettings()

realmSettings

protected org.opensearch.client.opensearch.indices.IndexSettings realmSettings()

auditSettings

protected org.opensearch.client.opensearch.indices.IndexSettings auditSettings()

userMapping

protected org.opensearch.client.opensearch._types.mapping.TypeMapping userMapping()

groupMapping

protected org.opensearch.client.opensearch._types.mapping.TypeMapping groupMapping()

anyObjectMapping

protected org.opensearch.client.opensearch._types.mapping.TypeMapping anyObjectMapping()

realmMapping

protected org.opensearch.client.opensearch._types.mapping.TypeMapping realmMapping()

auditMapping

protected org.opensearch.client.opensearch._types.mapping.TypeMapping auditMapping()

doExecute

protected String doExecute(JobExecutionContext context)
                    throws JobExecutionException

Description copied from class: AbstractSchedTaskJobDelegate

The actual execution, delegated to child classes.

Specified by:

doExecute in class AbstractSchedTaskJobDelegate<SchedTask>

Parameters:

context - job execution context, can be used to pass parameters to the job

Returns:

the task execution status to be set

Throws:

JobExecutionException - if anything goes wrong

hasToBeRegistered

protected boolean hasToBeRegistered(TaskExec<?> execution)

Description copied from class: AbstractSchedTaskJobDelegate

Template method to determine whether this job's task execution has to be persisted or not.

Overrides:

hasToBeRegistered in class AbstractSchedTaskJobDelegate<SchedTask>

Parameters:

execution - task execution

Returns:

whether to persist or not