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

Class ElasticsearchAuditEventDAO

java.lang.Object

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

All Implemented Interfaces:

AuditEventDAO

public class ElasticsearchAuditEventDAO
extends Object
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, 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, 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, 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 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,
 OpEvent.CategoryType type,
 String category,
 String subcategory,
 String op,
 OpEvent.Outcome outcome,
 OffsetDateTime before,
 OffsetDateTime after)

count

public long count(String entityKey,
 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,
 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