Interface StreamReferencesArgs<T>

All Known Subinterfaces:
StreamAckArgs, StreamRemoveArgs, StreamTrimReferencesArgs<T>
All Known Implementing Classes:
BaseReferencesParams, StreamAckParams, StreamAddParams, StreamRemoveParams, StreamTrimParams

public interface StreamReferencesArgs<T>
Author:
seakider
  • Method Summary

    Modifier and Type
    Method
    Description
    Defines KEEPREF reference policy for consumer groups when trimming.
    Defines ACKED reference policy for consumer groups when trimming.
    Defines DELREF reference policy for consumer groups when trimming.
  • Method Details

    • removeReferences

      T removeReferences()
      Defines DELREF reference policy for consumer groups when trimming. When trimming, removes all references from consumer groups’ PEL Requires Redis 8.2.0 and higher.
      Returns:
      arguments object
    • keepReferences

      T keepReferences()
      Defines KEEPREF reference policy for consumer groups when trimming. When trimming, preserves references in consumer groups’ PEL Requires Redis 8.2.0 and higher.
      Returns:
      arguments object
    • removeAcknowledgedOnly

      T removeAcknowledgedOnly()
      Defines ACKED reference policy for consumer groups when trimming. When trimming, only removes entries acknowledged by all consumer groups Requires Redis 8.2.0 and higher.
      Returns:
      arguments object