org.apache.syncope.ext.elasticsearch.client

Class ElasticsearchUtils

java.lang.Object

org.apache.syncope.ext.elasticsearch.client.ElasticsearchUtils

public class ElasticsearchUtils
extends Object

Utility methods for usage with Elasticsearch.

Field Summary

Fields

Modifier and Type	Field and Description
protected AnyObjectDAO	anyObjectDAO
protected GroupDAO	groupDAO
protected int	indexMaxResultWindow
protected int	numberOfReplicas
protected int	numberOfShards
protected int	retryOnConflict
protected UserDAO	userDAO

Constructor Summary

Constructors

Constructor and Description
ElasticsearchUtils()

Method Summary

Modifier and Type	Method and Description
org.elasticsearch.xcontent.XContentBuilder	builder(Any<?> any, String domain) Returns the builder specialized with content from the provided any.
org.elasticsearch.xcontent.XContentBuilder	builder(long instant, AuditEntry message, String domain)
protected org.elasticsearch.xcontent.XContentBuilder	customizeBuilder(org.elasticsearch.xcontent.XContentBuilder builder, AnyObject anyObject, String domain)
protected org.elasticsearch.xcontent.XContentBuilder	customizeBuilder(org.elasticsearch.xcontent.XContentBuilder builder, Group group, String domain)
protected org.elasticsearch.xcontent.XContentBuilder	customizeBuilder(org.elasticsearch.xcontent.XContentBuilder builder, long instant, AuditEntry message, String domain)
protected org.elasticsearch.xcontent.XContentBuilder	customizeBuilder(org.elasticsearch.xcontent.XContentBuilder builder, User user, String domain)
static String	getAnyIndex(String domain, AnyTypeKind kind)
static String	getAuditIndex(String domain)
int	getIndexMaxResultWindow()
int	getNumberOfReplicas()
int	getNumberOfShards()
int	getRetryOnConflict()
void	setIndexMaxResultWindow(int indexMaxResultWindow)
void	setNumberOfReplicas(int numberOfReplicas)
void	setNumberOfShards(int numberOfShards)
void	setRetryOnConflict(int retryOnConflict)

Methods inherited from class java.lang.Object

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

Field Detail

userDAO

@Autowired
protected UserDAO userDAO

groupDAO

@Autowired
protected GroupDAO groupDAO

anyObjectDAO

@Autowired
protected AnyObjectDAO anyObjectDAO

indexMaxResultWindow

protected int indexMaxResultWindow

retryOnConflict

protected int retryOnConflict

numberOfShards

protected int numberOfShards

numberOfReplicas

protected int numberOfReplicas

Constructor Detail

ElasticsearchUtils

public ElasticsearchUtils()

Method Detail

getAnyIndex

public static String getAnyIndex(String domain,
                                 AnyTypeKind kind)

getAuditIndex

public static String getAuditIndex(String domain)

setIndexMaxResultWindow

public void setIndexMaxResultWindow(int indexMaxResultWindow)

getIndexMaxResultWindow

public int getIndexMaxResultWindow()

setRetryOnConflict

public void setRetryOnConflict(int retryOnConflict)

getRetryOnConflict

public int getRetryOnConflict()

getNumberOfShards

public int getNumberOfShards()

setNumberOfShards

public void setNumberOfShards(int numberOfShards)

getNumberOfReplicas

public int getNumberOfReplicas()

setNumberOfReplicas

public void setNumberOfReplicas(int numberOfReplicas)

builder

@Transactional
public org.elasticsearch.xcontent.XContentBuilder builder(Any<?> any,
                                                                         String domain)
                                                                  throws IOException

Returns the builder specialized with content from the provided any.

Parameters:

any - user, group or any object to index

domain - tenant information

Returns:

builder specialized with content from the provided any

Throws:

IOException - in case of errors

customizeBuilder

protected org.elasticsearch.xcontent.XContentBuilder customizeBuilder(org.elasticsearch.xcontent.XContentBuilder builder,
                                                                      AnyObject anyObject,
                                                                      String domain)
                                                               throws IOException

Throws:

IOException

customizeBuilder

protected org.elasticsearch.xcontent.XContentBuilder customizeBuilder(org.elasticsearch.xcontent.XContentBuilder builder,
                                                                      Group group,
                                                                      String domain)
                                                               throws IOException

Throws:

IOException

customizeBuilder

protected org.elasticsearch.xcontent.XContentBuilder customizeBuilder(org.elasticsearch.xcontent.XContentBuilder builder,
                                                                      User user,
                                                                      String domain)
                                                               throws IOException

Throws:

IOException

builder

public org.elasticsearch.xcontent.XContentBuilder builder(long instant,
                                                          AuditEntry message,
                                                          String domain)
                                                   throws IOException

Throws:

IOException

customizeBuilder

protected org.elasticsearch.xcontent.XContentBuilder customizeBuilder(org.elasticsearch.xcontent.XContentBuilder builder,
                                                                      long instant,
                                                                      AuditEntry message,
                                                                      String domain)
                                                               throws IOException

Throws:

IOException