Package org.graylog.events.processor

Class DBEventDefinitionService

java.lang.Object

org.graylog.events.processor.DBEventDefinitionService

public class DBEventDefinitionService
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final String	COLLECTION_NAME

Constructor Summary

Constructors

Constructor	Description
DBEventDefinitionService(MongoCollections mongoCollections, DBEventProcessorStateService stateService, EntityOwnershipService entityOwnerShipService, EntityScopeService entityScopeService, SearchFiltersReFetcher searchFiltersRefetcher)

Method Summary

Modifier and Type	Method	Description
int	delete(String id)
long	deleteUnregister(String id)
long	deleteUnregisterImmutable(String id)
void	forceDelete(String id)
Optional<EventDefinitionDto>	get(String id)
@NotNull List<EventDefinitionDto>	getByArrayValue(String arrayField, String field, String value)	Returns the list of event definitions that contain the given value in the specified array field
List<EventDefinitionDto>	getByNotificationId(String notificationId)	Returns the list of event definitions that is using the given notification ID.
List<EventDefinitionDto>	getSystemEventDefinitions()	Returns the list of system event definitions
boolean	isMutable(EventDefinitionDto eventDefinition)
EventDefinitionDto	save(EventDefinitionDto entity)
EventDefinitionDto	saveWithOwnership(EventDefinitionDto eventDefinitionDto, User user)
PaginatedList<EventDefinitionDto>	searchPaginated(SearchQuery query, Predicate<EventDefinitionDto> filter, org.bson.conversions.Bson sort, int page, int perPage)
Stream<EventDefinitionDto>	streamAll()
void	updateMatchedAt(String id, org.joda.time.DateTime timeStamp)
void	updateState(String id, EventDefinition.State state)

Methods inherited from class java.lang.Object

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

Field Details

COLLECTION_NAME

public static final String COLLECTION_NAME

See Also:

• Constant Field Values

Constructor Details

DBEventDefinitionService

@Inject
public DBEventDefinitionService(MongoCollections mongoCollections,
 DBEventProcessorStateService stateService,
 EntityOwnershipService entityOwnerShipService,
 EntityScopeService entityScopeService,
 SearchFiltersReFetcher searchFiltersRefetcher)

Method Details

searchPaginated

public PaginatedList<EventDefinitionDto> searchPaginated(SearchQuery query,
 Predicate<EventDefinitionDto> filter,
 org.bson.conversions.Bson sort,
 int page,
 int perPage)

saveWithOwnership

public EventDefinitionDto saveWithOwnership(EventDefinitionDto eventDefinitionDto,
 User user)

save

public EventDefinitionDto save(EventDefinitionDto entity)

get

public Optional<EventDefinitionDto> get(String id)

updateMatchedAt

public void updateMatchedAt(String id,
 org.joda.time.DateTime timeStamp)

updateState

public void updateState(String id,
 EventDefinition.State state)

delete

public int delete(String id)

forceDelete

public void forceDelete(String id)

deleteUnregister

public long deleteUnregister(String id)

deleteUnregisterImmutable

public long deleteUnregisterImmutable(String id)

getByNotificationId

public List<EventDefinitionDto> getByNotificationId(String notificationId)

Returns the list of event definitions that is using the given notification ID.

Parameters:

notificationId - the notification ID

Returns:

the event definitions with the given notification ID

getSystemEventDefinitions

public List<EventDefinitionDto> getSystemEventDefinitions()

Returns the list of system event definitions

Returns:

the matching event definitions

getByArrayValue

@NotNull
public @NotNull List<EventDefinitionDto> getByArrayValue(String arrayField,
 String field,
 String value)

Returns the list of event definitions that contain the given value in the specified array field

isMutable

public boolean isMutable(EventDefinitionDto eventDefinition)

streamAll

public Stream<EventDefinitionDto> streamAll()