Package org.redisson.api

Interface RTransactionRx

public interface RTransactionRx
RxJava2 interface for transaction object allows to execute transactions over Redisson objects. Uses locks for write operations and maintains data modification operations list till the commit/rollback operation.

Transaction isolation level: READ_COMMITTED

  • Method Summary

    Modifier and Type
    Method
    Description
    io.reactivex.rxjava3.core.Completable
    commit()
    Commits all changes made on this transaction.
    <V> RBucketRx<V>
    getBucket(String name)
    Returns transactional object holder instance by name.
    <V> RBucketRx<V>
    getBucket(String name, Codec codec)
    Returns transactional object holder instance by name using provided codec for object.
    <K, V> RMapRx<K,V>
    getMap(String name)
    Returns transactional map instance by name.
    <K, V> RMapRx<K,V>
    getMap(String name, Codec codec)
    Returns transactional map instance by name using provided codec for both map keys and values.
    <K, V> RMapCacheRx<K,V>
    getMapCache(String name)
    Returns transactional map-based cache instance by name.
    <K, V> RMapCacheRx<K,V>
    getMapCache(String name, Codec codec)
    Returns transactional map-based cache instance by name using provided codec for both cache keys and values.
    <V> RSetRx<V>
    getSet(String name)
    Returns transactional set instance by name.
    <V> RSetRx<V>
    getSet(String name, Codec codec)
    Returns transactional set instance by name using provided codec for set objects.
    <V> RSetCacheRx<V>
    getSetCache(String name)
    Returns transactional set-based cache instance by name.
    <V> RSetCacheRx<V>
    getSetCache(String name, Codec codec)
    Returns transactional set-based cache instance by name.
    io.reactivex.rxjava3.core.Completable
    rollback()
    Rollback all changes made on this transaction.

  • Method Details

    • getBucket

      <V> RBucketRx<V> getBucket(String name)
      Returns transactional object holder instance by name.
      Type Parameters:
      V - type of value
      Parameters:
      name - - name of object
      Returns:
      Bucket object

    • getBucket

      <V> RBucketRx<V> getBucket(String name, Codec codec)
      Returns transactional object holder instance by name using provided codec for object.
      Type Parameters:
      V - type of value
      Parameters:
      name - - name of object
      codec - - codec for values
      Returns:
      Bucket object

    • getMap

      <K, V> RMapRx<K,V> getMap(String name)
      Returns transactional map instance by name.
      Type Parameters:
      K - type of key
      V - type of value
      Parameters:
      name - - name of object
      Returns:
      Map object

    • getMap

      <K, V> RMapRx<K,V> getMap(String name, Codec codec)
      Returns transactional map instance by name using provided codec for both map keys and values.
      Type Parameters:
      K - type of key
      V - type of value
      Parameters:
      name - - name of object
      codec - - codec for keys and values
      Returns:
      Map object

    • getSet

      <V> RSetRx<V> getSet(String name)
      Returns transactional set instance by name.
      Type Parameters:
      V - type of value
      Parameters:
      name - - name of object
      Returns:
      Set object

    • getSet

      <V> RSetRx<V> getSet(String name, Codec codec)
      Returns transactional set instance by name using provided codec for set objects.
      Type Parameters:
      V - type of value
      Parameters:
      name - - name of object
      codec - - codec for values
      Returns:
      Set object

    • getSetCache

      <V> RSetCacheRx<V> getSetCache(String name)
      Returns transactional set-based cache instance by name. Supports value eviction with a given TTL value.

      If eviction is not required then it's better to use regular map getSet(String).

      Type Parameters:
      V - type of value
      Parameters:
      name - - name of object
      Returns:
      SetCache object

    • getSetCache

      <V> RSetCacheRx<V> getSetCache(String name, Codec codec)
      Returns transactional set-based cache instance by name. Supports value eviction with a given TTL value.

      If eviction is not required then it's better to use regular map getSet(String, Codec).

      Type Parameters:
      V - type of value
      Parameters:
      name - - name of object
      codec - - codec for values
      Returns:
      SetCache object

    • getMapCache

      <K, V> RMapCacheRx<K,V> getMapCache(String name)
      Returns transactional map-based cache instance by name. Supports entry eviction with a given MaxIdleTime and TTL settings.

      If eviction is not required then it's better to use regular map getMap(String).

      Type Parameters:
      K - type of key
      V - type of value
      Parameters:
      name - - name of object
      Returns:
      MapCache object

    • getMapCache

      <K, V> RMapCacheRx<K,V> getMapCache(String name, Codec codec)
      Returns transactional map-based cache instance by name using provided codec for both cache keys and values. Supports entry eviction with a given MaxIdleTime and TTL settings.

      If eviction is not required then it's better to use regular map getMap(String, Codec).

      Type Parameters:
      K - type of key
      V - type of value
      Parameters:
      name - - object name
      codec - - codec for keys and values
      Returns:
      MapCache object

    • commit

      io.reactivex.rxjava3.core.Completable commit()
      Commits all changes made on this transaction.
      Returns:
      void

    • rollback

      io.reactivex.rxjava3.core.Completable rollback()
      Rollback all changes made on this transaction.
      Returns:
      void