Package org.apache.syncope.core.persistence.elasticsearch.dao

Class ElasticsearchAuditEventDAO

java.lang.Object

org.apache.syncope.core.persistence.common.dao.AbstractAuditEventDAO

org.apache.syncope.core.persistence.elasticsearch.dao.ElasticsearchAuditEventDAO

All Implemented Interfaces:

AuditEventDAO

public class ElasticsearchAuditEventDAO
extends AbstractAuditEventDAO
implements AuditEventDAO

Field Summary

Fields

Modifier and Type	Field	Description
protected final co.elastic.clients.elasticsearch.ElasticsearchClient	client
protected final ElasticsearchIndexManager	indexManager
protected final int	indexMaxResultWindow
protected static final Logger	LOG

Constructor Summary

Constructors

Constructor	Description
ElasticsearchAuditEventDAO(ElasticsearchIndexManager indexManager, co.elastic.clients.elasticsearch.ElasticsearchClient client, int indexMaxResultWindow)

Method Summary

Modifier and Type	Method	Description
long	count(String entityKey, Set<String> username, Set<String> who, OpEvent.CategoryType type, String category, String subcategory, String op, OpEvent.Outcome outcome, OffsetDateTime before, OffsetDateTime after)
protected co.elastic.clients.elasticsearch._types.query_dsl.Query	getQuery(String entityKey, Set<String> username, Set<String> who, OpEvent.CategoryType type, String category, String subcategory, String op, OpEvent.Outcome outcome, OffsetDateTime before, OffsetDateTime after)
AuditEvent	save(AuditEvent auditEvent)
List<AuditEventTO>	search(String entityKey, Set<String> username, Set<String> who, OpEvent.CategoryType type, String category, String subcategory, String op, OpEvent.Outcome outcome, OffsetDateTime before, OffsetDateTime after, org.springframework.data.domain.Pageable pageable)
protected List<co.elastic.clients.elasticsearch._types.SortOptions>	sortBuilders(Stream<org.springframework.data.domain.Sort.Order> orderBy)

Methods inherited from class org.apache.syncope.core.persistence.common.dao.AbstractAuditEventDAO

checkEntityKey, escapeForLike, filterOrderBy, toOpEvent

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.syncope.core.persistence.api.dao.AuditEventDAO

toAuditEventTO

Field Details

LOG

protected static final Logger LOG

indexManager

protected final ElasticsearchIndexManager indexManager

client

protected final co.elastic.clients.elasticsearch.ElasticsearchClient client

indexMaxResultWindow

protected final int indexMaxResultWindow

Constructor Details

ElasticsearchAuditEventDAO

public ElasticsearchAuditEventDAO(ElasticsearchIndexManager indexManager,
 co.elastic.clients.elasticsearch.ElasticsearchClient client,
 int indexMaxResultWindow)

Method Details

save

public AuditEvent save(AuditEvent auditEvent)

Specified by:

save in interface AuditEventDAO

getQuery

protected co.elastic.clients.elasticsearch._types.query_dsl.Query getQuery(String entityKey,
 Set<String> username,
 Set<String> who,
 OpEvent.CategoryType type,
 String category,
 String subcategory,
 String op,
 OpEvent.Outcome outcome,
 OffsetDateTime before,
 OffsetDateTime after)

count

public long count(String entityKey,
 Set<String> username,
 Set<String> who,
 OpEvent.CategoryType type,
 String category,
 String subcategory,
 String op,
 OpEvent.Outcome outcome,
 OffsetDateTime before,
 OffsetDateTime after)

Specified by:

count in interface AuditEventDAO

sortBuilders

protected List<co.elastic.clients.elasticsearch._types.SortOptions> sortBuilders(Stream<org.springframework.data.domain.Sort.Order> orderBy)

search

public List<AuditEventTO> search(String entityKey,
 Set<String> username,
 Set<String> who,
 OpEvent.CategoryType type,
 String category,
 String subcategory,
 String op,
 OpEvent.Outcome outcome,
 OffsetDateTime before,
 OffsetDateTime after,
 org.springframework.data.domain.Pageable pageable)

Specified by:

search in interface AuditEventDAO