Package org.graylog2.streams.filters

Class StreamDestinationFilterService

java.lang.Object

org.graylog2.streams.filters.StreamDestinationFilterService

public class StreamDestinationFilterService
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	StreamDestinationFilterService.GroupByStreamResult

Field Summary

Fields

Modifier and Type	Field	Description
static final String	COLLECTION

Constructor Summary

Constructors

Constructor	Description
StreamDestinationFilterService(MongoCollections mongoCollections, ClusterEventBus clusterEventBus, com.google.common.eventbus.EventBus eventBus, Optional<DestinationFilterCreationValidator> optionalDestinationFilterCreationValidator)

Method Summary

Modifier and Type	Method	Description
StreamDestinationFilterRuleDTO	createForStream(String streamId, StreamDestinationFilterRuleDTO dto)
StreamDestinationFilterRuleDTO	deleteFromStream(String streamId, String id)
Optional<StreamDestinationFilterRuleDTO>	findByIdForStream(String streamId, String id)
PaginatedList<StreamDestinationFilterRuleDTO>	findPaginatedForStream(String streamId, String queryString, org.bson.conversions.Bson sort, int perPage, int page, Predicate<String> permissionSelector)
PaginatedList<StreamDestinationFilterRuleDTO>	findPaginatedForStreamAndTarget(String streamId, String targetId, String queryString, org.bson.conversions.Bson sort, int perPage, int page, Predicate<String> permissionSelector)
void	forEachEnabledFilterGroupedByStream(Consumer<StreamDestinationFilterService.GroupByStreamResult> consumer)
void	handleStreamDeleted(StreamDeletedEvent streamDeletedEvent)
StreamDestinationFilterRuleDTO	updateForStream(String streamId, StreamDestinationFilterRuleDTO dto)

Methods inherited from class java.lang.Object

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

Field Details

COLLECTION

public static final String COLLECTION

See Also:

• Constant Field Values

Constructor Details

StreamDestinationFilterService

@Inject
public StreamDestinationFilterService(MongoCollections mongoCollections,
 ClusterEventBus clusterEventBus,
 com.google.common.eventbus.EventBus eventBus,
 Optional<DestinationFilterCreationValidator> optionalDestinationFilterCreationValidator)

Method Details

findPaginatedForStream

public PaginatedList<StreamDestinationFilterRuleDTO> findPaginatedForStream(String streamId,
 String queryString,
 org.bson.conversions.Bson sort,
 int perPage,
 int page,
 Predicate<String> permissionSelector)

findPaginatedForStreamAndTarget

public PaginatedList<StreamDestinationFilterRuleDTO> findPaginatedForStreamAndTarget(String streamId,
 String targetId,
 String queryString,
 org.bson.conversions.Bson sort,
 int perPage,
 int page,
 Predicate<String> permissionSelector)

findByIdForStream

public Optional<StreamDestinationFilterRuleDTO> findByIdForStream(String streamId,
 String id)

createForStream

public StreamDestinationFilterRuleDTO createForStream(String streamId,
 StreamDestinationFilterRuleDTO dto)

updateForStream

public StreamDestinationFilterRuleDTO updateForStream(String streamId,
 StreamDestinationFilterRuleDTO dto)

deleteFromStream

public StreamDestinationFilterRuleDTO deleteFromStream(String streamId,
 String id)

forEachEnabledFilterGroupedByStream

public void forEachEnabledFilterGroupedByStream(Consumer<StreamDestinationFilterService.GroupByStreamResult> consumer)

handleStreamDeleted

public void handleStreamDeleted(StreamDeletedEvent streamDeletedEvent)