Package org.apache.syncope.ext.opensearch.client

Class OpenSearchIndexManager

java.lang.Object

org.apache.syncope.ext.opensearch.client.OpenSearchIndexManager

public class OpenSearchIndexManager
extends Object

Listen to any create / update and delete in order to keep the OpenSearch indexes consistent.

Field Summary

Fields

Modifier and Type	Field	Description
protected final org.opensearch.client.opensearch.OpenSearchClient	client
protected final Integer	numberOfReplicas
protected final Integer	numberOfShards
protected final OpenSearchUtils	openSearchUtils

Constructor Summary

Constructors

Constructor	Description
OpenSearchIndexManager(org.opensearch.client.opensearch.OpenSearchClient client, OpenSearchUtils ppenSearchUtils, Integer numberOfShards, Integer numberOfReplicas)

Method Summary

Modifier and Type	Method	Description
void	audit(String domain, AuditEvent auditEvent)
void	createAnyIndex(String domain, AnyTypeKind kind, org.opensearch.client.opensearch.indices.IndexSettings settings, org.opensearch.client.opensearch._types.mapping.TypeMapping mappings)
void	createAuditIndex(String domain, org.opensearch.client.opensearch.indices.IndexSettings settings, org.opensearch.client.opensearch._types.mapping.TypeMapping mappings)
void	createRealmIndex(String domain, org.opensearch.client.opensearch.indices.IndexSettings settings, org.opensearch.client.opensearch._types.mapping.TypeMapping mappings)
org.opensearch.client.opensearch._types.mapping.TypeMapping	defaultAnyMapping()
org.opensearch.client.opensearch._types.mapping.TypeMapping	defaultAuditMapping()
org.opensearch.client.opensearch._types.mapping.TypeMapping	defaultRealmMapping()
org.opensearch.client.opensearch.indices.IndexSettings	defaultSettings()
protected org.opensearch.client.opensearch.indices.CreateIndexResponse	doCreateAnyIndex(String domain, AnyTypeKind kind, org.opensearch.client.opensearch.indices.IndexSettings settings, org.opensearch.client.opensearch._types.mapping.TypeMapping mappings)
protected org.opensearch.client.opensearch.indices.CreateIndexResponse	doCreateAuditIndex(String domain, org.opensearch.client.opensearch.indices.IndexSettings settings, org.opensearch.client.opensearch._types.mapping.TypeMapping mappings)
protected org.opensearch.client.opensearch.indices.CreateIndexResponse	doCreateRealmIndex(String domain, org.opensearch.client.opensearch.indices.IndexSettings settings, org.opensearch.client.opensearch._types.mapping.TypeMapping mappings)
void	entity(EntityLifecycleEvent<Entity> event)
boolean	existsAnyIndex(String domain, AnyTypeKind kind)
boolean	existsAuditIndex(String domain)
boolean	existsRealmIndex(String domain)
void	removeAnyIndex(String domain, AnyTypeKind kind)
void	removeAuditIndex(String domain)
void	removeRealmIndex(String domain)

Methods inherited from class java.lang.Object

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

Field Details

client

protected final org.opensearch.client.opensearch.OpenSearchClient client

openSearchUtils

protected final OpenSearchUtils openSearchUtils

numberOfShards

protected final Integer numberOfShards

numberOfReplicas

protected final Integer numberOfReplicas

Constructor Details

OpenSearchIndexManager

public OpenSearchIndexManager(org.opensearch.client.opensearch.OpenSearchClient client,
 OpenSearchUtils ppenSearchUtils,
 Integer numberOfShards,
 Integer numberOfReplicas)

Method Details

existsAnyIndex

public boolean existsAnyIndex(String domain,
 AnyTypeKind kind)
                       throws IOException

Throws:

IOException

existsRealmIndex

public boolean existsRealmIndex(String domain)
                         throws IOException

Throws:

IOException

existsAuditIndex

public boolean existsAuditIndex(String domain)
                         throws IOException

Throws:

IOException

defaultSettings

public org.opensearch.client.opensearch.indices.IndexSettings defaultSettings()

defaultAnyMapping

public org.opensearch.client.opensearch._types.mapping.TypeMapping defaultAnyMapping()

defaultRealmMapping

public org.opensearch.client.opensearch._types.mapping.TypeMapping defaultRealmMapping()

defaultAuditMapping

public org.opensearch.client.opensearch._types.mapping.TypeMapping defaultAuditMapping()

doCreateAnyIndex

protected org.opensearch.client.opensearch.indices.CreateIndexResponse doCreateAnyIndex(String domain,
 AnyTypeKind kind,
 org.opensearch.client.opensearch.indices.IndexSettings settings,
 org.opensearch.client.opensearch._types.mapping.TypeMapping mappings)
                                                                                 throws IOException

Throws:

IOException

createAnyIndex

public void createAnyIndex(String domain,
 AnyTypeKind kind,
 org.opensearch.client.opensearch.indices.IndexSettings settings,
 org.opensearch.client.opensearch._types.mapping.TypeMapping mappings)
                    throws IOException

Throws:

IOException

removeAnyIndex

public void removeAnyIndex(String domain,
 AnyTypeKind kind)
                    throws IOException

Throws:

IOException

doCreateRealmIndex

protected org.opensearch.client.opensearch.indices.CreateIndexResponse doCreateRealmIndex(String domain,
 org.opensearch.client.opensearch.indices.IndexSettings settings,
 org.opensearch.client.opensearch._types.mapping.TypeMapping mappings)
                                                                                   throws IOException

Throws:

IOException

createRealmIndex

public void createRealmIndex(String domain,
 org.opensearch.client.opensearch.indices.IndexSettings settings,
 org.opensearch.client.opensearch._types.mapping.TypeMapping mappings)
                      throws IOException

Throws:

IOException

removeRealmIndex

public void removeRealmIndex(String domain)
                      throws IOException

Throws:

IOException

doCreateAuditIndex

protected org.opensearch.client.opensearch.indices.CreateIndexResponse doCreateAuditIndex(String domain,
 org.opensearch.client.opensearch.indices.IndexSettings settings,
 org.opensearch.client.opensearch._types.mapping.TypeMapping mappings)
                                                                                   throws IOException

Throws:

IOException

createAuditIndex

public void createAuditIndex(String domain,
 org.opensearch.client.opensearch.indices.IndexSettings settings,
 org.opensearch.client.opensearch._types.mapping.TypeMapping mappings)
                      throws IOException

Throws:

IOException

removeAuditIndex

public void removeAuditIndex(String domain)
                      throws IOException

Throws:

IOException

entity

@TransactionalEventListener
public void entity(EntityLifecycleEvent<Entity> event)
            throws IOException

Throws:

IOException

audit

public void audit(String domain,
 AuditEvent auditEvent)
           throws IOException

Throws:

IOException