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 org.opensearch.client.opensearch.OpenSearchClient	client
protected String	numberOfReplicas
protected String	numberOfShards
protected OpenSearchUtils	openSearchUtils

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	audit(String domain, long instant, JsonNode message)
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 Detail

client

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

openSearchUtils

protected final OpenSearchUtils openSearchUtils

numberOfShards

protected final String numberOfShards

numberOfReplicas

protected final String numberOfReplicas

Constructor Detail

OpenSearchIndexManager

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

Method Detail

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()
                                                                       throws IOException

Throws:

IOException

defaultAnyMapping

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

Throws:

IOException

defaultRealmMapping

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

Throws:

IOException

defaultAuditMapping

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

Throws:

IOException

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,
                  long instant,
                  JsonNode message)
           throws IOException

Throws:

IOException