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

Class OpenSearchAuditEventDAO

java.lang.Object

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

org.apache.syncope.core.persistence.opensearch.dao.OpenSearchAuditEventDAO

All Implemented Interfaces:

AuditEventDAO

public class OpenSearchAuditEventDAO
extends AbstractAuditEventDAO
implements AuditEventDAO

Field Summary

Fields

Modifier and Type	Field	Description
protected final org.opensearch.client.opensearch.OpenSearchClient	client
protected final OpenSearchIndexManager	indexManager
protected final int	indexMaxResultWindow
protected static final Logger	LOG

Constructor Summary

Constructors

Constructor	Description
OpenSearchAuditEventDAO(OpenSearchIndexManager indexManager, org.opensearch.client.opensearch.OpenSearchClient 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 org.opensearch.client.opensearch._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<org.opensearch.client.opensearch._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 OpenSearchIndexManager indexManager

client

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

indexMaxResultWindow

protected final int indexMaxResultWindow

Constructor Details

OpenSearchAuditEventDAO

public OpenSearchAuditEventDAO(OpenSearchIndexManager indexManager,
 org.opensearch.client.opensearch.OpenSearchClient client,
 int indexMaxResultWindow)

Method Details

save

public AuditEvent save(AuditEvent auditEvent)

Specified by:

save in interface AuditEventDAO

getQuery

protected org.opensearch.client.opensearch._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<org.opensearch.client.opensearch._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