org.apache.syncope.ext.elasticsearch.client

Class ElasticsearchIndexManager

java.lang.Object

org.apache.syncope.ext.elasticsearch.client.ElasticsearchIndexManager

public class ElasticsearchIndexManager
extends Object

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

Field Summary

Fields

Modifier and Type	Field and Description
protected org.elasticsearch.client.RestHighLevelClient	client
protected ElasticsearchUtils	elasticsearchUtils

Constructor Summary

Constructors

Constructor and Description
ElasticsearchIndexManager(org.elasticsearch.client.RestHighLevelClient client, ElasticsearchUtils elasticsearchUtils)

Method Summary

Modifier and Type	Method and Description
void	any(AnyLifecycleEvent<Any<?>> event)
void	audit(String domain, long instant, AuditEntry message)
void	createAnyIndex(String domain, AnyTypeKind kind, org.elasticsearch.xcontent.XContentBuilder settings, org.elasticsearch.xcontent.XContentBuilder mapping)
void	createAuditIndex(String domain, org.elasticsearch.xcontent.XContentBuilder settings, org.elasticsearch.xcontent.XContentBuilder mapping)
org.elasticsearch.xcontent.XContentBuilder	defaultAnyMapping()
org.elasticsearch.xcontent.XContentBuilder	defaultAuditMapping()
org.elasticsearch.xcontent.XContentBuilder	defaultSettings()
protected org.elasticsearch.client.indices.CreateIndexResponse	doCreateAnyIndex(String domain, AnyTypeKind kind, org.elasticsearch.xcontent.XContentBuilder settings, org.elasticsearch.xcontent.XContentBuilder mapping)
protected org.elasticsearch.client.indices.CreateIndexResponse	doCreateAuditIndex(String domain, org.elasticsearch.xcontent.XContentBuilder settings, org.elasticsearch.xcontent.XContentBuilder mapping)
boolean	existsAnyIndex(String domain, AnyTypeKind kind)
boolean	existsAuditIndex(String domain)
void	removeAnyIndex(String domain, AnyTypeKind kind)
void	removeAuditIndex(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.elasticsearch.client.RestHighLevelClient client

elasticsearchUtils

protected final ElasticsearchUtils elasticsearchUtils

Constructor Detail

ElasticsearchIndexManager

public ElasticsearchIndexManager(org.elasticsearch.client.RestHighLevelClient client,
                                 ElasticsearchUtils elasticsearchUtils)

Method Detail

existsAnyIndex

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

Throws:

IOException

existsAuditIndex

public boolean existsAuditIndex(String domain)
                         throws IOException

Throws:

IOException

defaultSettings

public org.elasticsearch.xcontent.XContentBuilder defaultSettings()
                                                           throws IOException

Throws:

IOException

defaultAnyMapping

public org.elasticsearch.xcontent.XContentBuilder defaultAnyMapping()
                                                             throws IOException

Throws:

IOException

defaultAuditMapping

public org.elasticsearch.xcontent.XContentBuilder defaultAuditMapping()
                                                               throws IOException

Throws:

IOException

doCreateAnyIndex

protected org.elasticsearch.client.indices.CreateIndexResponse doCreateAnyIndex(String domain,
                                                                                AnyTypeKind kind,
                                                                                org.elasticsearch.xcontent.XContentBuilder settings,
                                                                                org.elasticsearch.xcontent.XContentBuilder mapping)
                                                                         throws IOException

Throws:

IOException

createAnyIndex

public void createAnyIndex(String domain,
                           AnyTypeKind kind,
                           org.elasticsearch.xcontent.XContentBuilder settings,
                           org.elasticsearch.xcontent.XContentBuilder mapping)
                    throws IOException

Throws:

IOException

removeAnyIndex

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

Throws:

IOException

doCreateAuditIndex

protected org.elasticsearch.client.indices.CreateIndexResponse doCreateAuditIndex(String domain,
                                                                                  org.elasticsearch.xcontent.XContentBuilder settings,
                                                                                  org.elasticsearch.xcontent.XContentBuilder mapping)
                                                                           throws IOException

Throws:

IOException

createAuditIndex

public void createAuditIndex(String domain,
                             org.elasticsearch.xcontent.XContentBuilder settings,
                             org.elasticsearch.xcontent.XContentBuilder mapping)
                      throws IOException

Throws:

IOException

removeAuditIndex

public void removeAuditIndex(String domain)
                      throws IOException

Throws:

IOException

any

@TransactionalEventListener
public void any(AnyLifecycleEvent<Any<?>> event)
                                     throws IOException

Throws:

IOException

audit

public void audit(String domain,
                  long instant,
                  AuditEntry message)
           throws IOException

Throws:

IOException