Package com.persequor.event

Interface IEventsQuery<T extends IEventsQuery<T>>

All Known Subinterfaces:
IElasticEventsQuery<T>, IRepositoryEventsQuery<T>
All Known Implementing Classes:
EventListQuery
public interface IEventsQuery<T extends IEventsQuery<T>>

  • Method Details

    • byMatchParentID

      T byMatchParentID(Collection<String> epcs)
      Filter this query by any of these parentIds. Setting this will also remove events without a parentId
      Parameters:
      epcs - parent ids allowed in the result
      Returns:
      this query instance
      See Also:

    • byMatchParentID

      T byMatchParentID(String... epcs)
      Filter this query by any of these parentIds. Setting this will also remove events without a parentId
      Parameters:
      epcs - parent ids allowed in the result
      Returns:
      this query instance
      See Also:

    • byEpcisEventId

      T byEpcisEventId(String... ids)
      Filter this query by any of these epcis event ids.
      Parameters:
      ids - epcis event ids allowed in the result
      Returns:
      this query instance

    • byEpcisEventId

      T byEpcisEventId(List<String> ids)
      Filter this query by any of these epcis event ids.
      Parameters:
      ids - epcis event ids allowed in the result
      Returns:
      this query instance

    • bySagaEventId

      T bySagaEventId(UUID... ids)
      Filter this query by any of these saga event ids.
      Parameters:
      ids - saga event ids allowed in the result
      Returns:
      this query instance

    • bySagaEventId

      T bySagaEventId(List<UUID> ids)
      Filter this query by any of these saga event ids.
      Parameters:
      ids - saga event ids allowed in the result
      Returns:
      this query instance

    • byMatchEpc

      T byMatchEpc(Collection<String> epcs)
      Filter this query by any of these EPCs.
      Parameters:
      epcs - allowed in the result
      Returns:
      this query instance
      See Also:

    • byMatchEpc

      T byMatchEpc(String... epcs)
      Filter this query by any of these EPCs
      Parameters:
      epcs - allowed in the result
      Returns:
      this query instance
      See Also:

    • byMatchAnyEPC

      T byMatchAnyEPC(Collection<String> anyEpcs)
      Filter this query by any of these EPCs in childEpc, parentId, inputEpc and epcList
      Parameters:
      anyEpcs - allowed in the result
      Returns:
      this query instance
      See Also:

    • byMatchAnyEPC

      T byMatchAnyEPC(String... anyEpcs)
      Filter this query by any of these EPCs in childEpc, parentId, inputEpc and epcList
      Parameters:
      anyEpcs - allowed in the result
      Returns:
      this query instance
      See Also:

    • byBizTransaction

      T byBizTransaction(String bizTransactionType, Collection<String> bizTransactions)
      Keep only events which have their business transaction type matching the provided one and business transaction value in the provided collection.

      This method uses exact matching unlike byMatchBizTransaction(String, String...)

      Parameters:
      bizTransactionType - allowed business transaction type in the result
      bizTransactions - allowed business transaction values in the result
      Returns:
      this query instance
      See Also:

    • byBizTransaction

      T byBizTransaction(String bizTransactionType, String... bizTransactions)
      Keep only events in result which have their business transaction type matching the provided one and business transaction value in the provided collection.

      This method uses exact matching unlike byMatchBizTransaction(String, Collection)

      Parameters:
      bizTransactionType - allowed business transaction type in the result
      bizTransactions - allowed business transaction values in the result
      Returns:
      this query instance
      See Also:

    • bySource

      T bySource(String sourceType, Collection<String> sources)
      Filter this query by any of these Sources.
      Parameters:
      sourceType - allowed source type in the result
      sources - allowed source values in the result
      Returns:
      this query instance
      See Also:

    • bySource

      T bySource(String sourceType, String... sources)
      Filter this query by any of these Sources.
      Parameters:
      sourceType - allowed source type in the result
      sources - allowed source values in the result
      Returns:
      this query instance
      See Also:

    • byDestination

      T byDestination(String destinationType, Collection<String> destinations)
      Keep only events in result which have their destination type matching the provided one and destination value in the provided collection.
      Parameters:
      destinationType - allowed destination type in the result
      destinations - allowed destination values in the result
      Returns:
      this query instance
      See Also:

    • byDestination

      T byDestination(String destinationType, String... destinations)
      Keep only events in result which have their destination type matching the provided one and destination value in the provided collection.
      Parameters:
      destinationType - allowed destination type in the result
      destinations - allowed destination values in the result
      Returns:
      this query instance
      See Also:

    • byMatchEpcClass

      T byMatchEpcClass(Collection<String> epcClasses)
      Filter by EPC classes from extension/quantityList/quantityElement/epcClass
      Parameters:
      epcClasses - allowed in the result
      Returns:
      this query instance

    • byMatchEpcClass

      default T byMatchEpcClass(String... epcClasses)
      Filter by EPC classes from extension/quantityList/quantityElement/epcClass
      Parameters:
      epcClasses - allowed in the result
      Returns:
      this query instance

    • byMatchAnyEpcClass

      T byMatchAnyEpcClass(Collection<String> epcClasses)
      Filter by EPC classes from both input and output quantityList
      Parameters:
      epcClasses - allowed in the result
      Returns:
      this query instance

    • byMatchAnyEpcClass

      default T byMatchAnyEpcClass(String... epcClasses)
      Filter by EPC classes from both input and output quantityList
      Parameters:
      epcClasses - allowed in the result
      Returns:
      this query instance

    • byEventType

      T byEventType(Collection<EventType> eventTypes)
      Filter this query by event type.
      Parameters:
      eventTypes - event types allowed in the result
      Returns:
      this query instance
      See Also:

    • byEventType

      T byEventType(EventType... eventTypes)
      Filter this query by any of these event types.
      Parameters:
      eventTypes - event types allowed in the result
      Returns:
      this query instance
      See Also:

    • byMatchBizTransaction

      T byMatchBizTransaction(String bizTransactionType, Collection<String> bizTransactionMatchStrings)
      Keep only events which have business transaction type similar to the provided one and business transaction value similar to one the provided collection.

      This method uses similar matching (trimming special characters) unlike byBizTransaction(String, String...)

      Parameters:
      bizTransactionType - allowed business transaction type in the result
      bizTransactionMatchStrings - allowed business transaction values in the result
      Returns:
      this query instance
      See Also:

    • byMatchBizTransaction

      T byMatchBizTransaction(String bizTransactionType, String... bizTransactionMatchStrings)
      Keep only events which have their business transaction type similar to the provided one and business transaction value similar to one the provided collection.

      This method uses similar matching like byBizTransaction(String, Collection)

      Parameters:
      bizTransactionType - allowed business transaction type in the result
      bizTransactionMatchStrings - allowed business transaction values in the result
      Returns:
      this query instance
      See Also:

    • byReadPoint

      T byReadPoint(Collection<String> readPoints)
      Filter this query by any of these read points.
      Parameters:
      readPoints - allowed read point value in the result
      Returns:
      this query instance

    • byAction

      T byAction(Collection<Action> actions)
      Filter this query by any of these actions. @see Action
      Parameters:
      actions - allowed in the result
      Returns:
      this query instance
      See Also:

    • byAction

      T byAction(Action... actions)
      Filter this query by any of these actions. @see Action
      Parameters:
      actions - allowed in the result
      Returns:
      this query instance
      See Also:

    • byBizStep

      T byBizStep(Collection<String> bizSteps)
      Filter this query by any of these business steps.
      Parameters:
      bizSteps - allowed in the result
      Returns:
      this query instance
      See Also:

    • byBizStep

      T byBizStep(String... bizSteps)
      Filter this query by any of these business steps.
      Parameters:
      bizSteps - allowed in the result
      Returns:
      this query instance
      See Also:

    • byDisposition

      T byDisposition(Collection<String> dispositions)
      Filter this query by any of these dispositions.
      Parameters:
      dispositions - allowed in the result
      Returns:
      this query instance
      See Also:

    • byDisposition

      T byDisposition(String... dispositions)
      Filter this query by any of these dispositions.
      Parameters:
      dispositions - allowed in the result
      Returns:
      this query instance
      See Also:

    • byBizLocation

      T byBizLocation(Collection<String> bizLocation)
      Filter this query by any of these business locations.
      Parameters:
      bizLocation - allowed in the result
      Returns:
      this query instance
      See Also:

    • byBizLocation

      T byBizLocation(String... bizLocation)
      Filter this query by any of these business locations.
      Parameters:
      bizLocation - allowed in the result
      Returns:
      this query instance
      See Also:

    • byRecordTime

      T byRecordTime(ZonedDateTime recordTimeFrom, ZonedDateTime recordTimeTo)
      Keep only events with record time greater or equal to recordTimeFrom and strictly less than recordTimeTo: recordTimeFrom <= record time < recordTimeTo
      Parameters:
      recordTimeFrom - lower inclusive bound of record time
      recordTimeTo - upper exclusive bound of record time
      Returns:
      this query instance

    • byGeRecordTime

      T byGeRecordTime(ZonedDateTime recordTime)
      Keep only events with record time greater or equal to recordTime
      Parameters:
      recordTime - lower inclusive bound of record time
      Returns:
      this query instance

    • byLtRecordTime

      T byLtRecordTime(ZonedDateTime recordTime)
      Keep only events with record time strictly less than recordTime
      Parameters:
      recordTime - upper exclusive bound of record time
      Returns:
      this query instance

    • byEventTime

      T byEventTime(ZonedDateTime eventTimeFrom, ZonedDateTime eventTimeTo)
      Keep only events with event time greater or equal to eventTimeFrom and strictly less than eventTimeTo: eventTimeFrom <= event time < eventTimeTo
      Parameters:
      eventTimeFrom - lower inclusive bound of event time
      eventTimeTo - upper exclusive bound of event time
      Returns:
      this query instance

    • byGeEventTime

      T byGeEventTime(ZonedDateTime eventTime)
      Keep only events with event time greater or equal to eventTime
      Parameters:
      eventTime - lower inclusive bound of event time
      Returns:
      this query instance

    • byLtEventTime

      T byLtEventTime(ZonedDateTime eventTime)
      Keep only events with event time strictly less than eventTimeTo
      Parameters:
      eventTime - upper exclusive bound of event time
      Returns:
      this query instance

    • filterRevertedEvents

      T filterRevertedEvents(boolean enableFilter)
      Sets whether original events should be cancelled out by their revert events from the repository response, such that they do not appear in the result. This overrides the default behavior set in the Saga configuration. (This feature is currently not supported in IEventListQuery).
      Parameters:
      enableFilter - true if this filter should be forcefully enabled, false if it should be forcefully disabled
      Returns:
      this query instance

    • bySagaEventIdentifiers

      T bySagaEventIdentifiers(List<SagaEventIdentifier> sagaEventIdentifiers)

    • withLimit

      T withLimit(Integer limit)

    • withOffset

      T withOffset(Integer limit)