public interface FilterInventory
Modifier and Type | Method and Description |
---|---|
CompletionStage<FilterEntry> |
createFilterEntry(FilterEntryParameters parameters,
String... acknowledgements)
Creates a filter entry according to the specified parameters.
|
CompletionStage<Void> |
deleteFilterEntry(String name,
String... acknowledgements)
Deletes the filter entry with the specified name.
|
PageIterator<FilterEntry> |
filterEntries(Filter filter,
int pageSize)
Returns a list of filter entries matching the specified filter, divided into pages.
|
PageIterator<FilterEntry> |
filterEntries(int pageSize)
Returns a list of all filter entries, divided into pages.
|
CompletionStage<Integer> |
filterEntriesCount(Filter filter)
Returns the number of filter entries matching the given filter.
|
CompletionStage<FilterEntry> |
filterEntry(String name)
Returns the filter entry with the specified name.
|
com.bosch.iot.dm.util.PageIterator<Subscription<List<FilterEntryEvent.Type>>> |
filterEntryEventSubscriptions(int pageSize)
Returns a list of filterEntry event subscriptions grouped in pages.
|
void |
subscribeForFilterEntryEvents(List<FilterEntryEvent.Type> types,
StreamConsumer<FilterEntryEvent> consumer)
Subscribe for
FilterEntry events. |
CompletionStage<Void> |
subscribeForFilterEntryEvents(String subscriptionId,
List<FilterEntryEvent.Type> types,
Target target)
Subscribe for
FilterEntry events. |
CompletionStage<Void> |
unsubscribeForFilterEntryEvents(String subscriptionId)
Delete a persistent subscription for
FilterEntry events with subscription id. |
CompletionStage<FilterEntry> filterEntry(String name)
name
- the name of the filter entryCompletionStage
providing the filter entry with the specified namePageIterator<FilterEntry> filterEntries(int pageSize)
pageSize
- the page sizePageIterator
providing a list of all filter entries, divided into pagesPageIterator<FilterEntry> filterEntries(Filter filter, int pageSize)
filter
- the filter to match againstpageSize
- the page sizePageIterator
providing a list of filter entries matching the specified filter, divided into pagesCompletionStage<FilterEntry> createFilterEntry(FilterEntryParameters parameters, String... acknowledgements)
parameters
- parameters of the filter entry to be createdacknowledgements
- requested acknowledgements for this operationCompletionStage
providing the newly created filter entryCompletionStage<Void> deleteFilterEntry(String name, String... acknowledgements)
name
- the name of the filter entry to be deletedacknowledgements
- requested acknowledgements for this operationCompletionStage
providing the result of the operationvoid subscribeForFilterEntryEvents(List<FilterEntryEvent.Type> types, StreamConsumer<FilterEntryEvent> consumer)
FilterEntry
events. This subscription is not persistent.types
- event types to subscribe for. Empty list will subscribe you for all event typesconsumer
- event consumerCompletionStage<Void> subscribeForFilterEntryEvents(String subscriptionId, List<FilterEntryEvent.Type> types, Target target)
FilterEntry
events. This subscription is persistent and must be deleted explicitly by the user using
unsubscribeForFilterEntryEvents(String)
.subscriptionId
- subscription id. The subscription id must be unique in the scope of the event source. Using this
subscription id the user may set consumer for the subscriptiontypes
- event types to subscribe for. Empty list will subscribe you for all event typestarget
- target where the events shall be sent toCompletionStage
that is completed successfully if the subscription has been finished and
exceptionally in case of failureCompletionStage<Void> unsubscribeForFilterEntryEvents(String subscriptionId)
FilterEntry
events with subscription id.subscriptionId
- subscription idCompletionStage
that is completed successfully if the subscription has been finished and
exceptionally in case of failurecom.bosch.iot.dm.util.PageIterator<Subscription<List<FilterEntryEvent.Type>>> filterEntryEventSubscriptions(int pageSize)
pageSize
- the number of subscriptions returned within a pageCompletionStage<Integer> filterEntriesCount(Filter filter)
filter
- the filter the filter entries to be returned to be matched againstCopyright © 2022 Bosch.IO GmbH. All rights reserved.