Package org.redisson.api

Interface RTransactionReactive

  • All Known Implementing Classes:
    RedissonTransactionReactive
    public interface RTransactionReactive
    Reactive 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

    Author:
    Nikita Koksharov

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      reactor.core.publisher.Mono<> commit()
      Commits all changes made on this transaction.
      <V> RBucketReactive<V>  name)
      Returns transactional object holder instance by name.
      <V> RBucketReactive<V>  name, Codec codec)
      Returns transactional object holder instance by name using provided codec for object.
      <K,​V>
      RMapReactive<K,​V>      		  name)
      Returns transactional map instance by name.
      <K,​V>
      RMapReactive<K,​V>      		  name, Codec codec)
      Returns transactional map instance by name using provided codec for both map keys and values.
      <K,​V>
      RMapCacheReactive<K,​V>      		  name)
      Returns transactional map-based cache instance by name.
      <K,​V>
      RMapCacheReactive<K,​V>      		  name, Codec codec)
      Returns transactional map-based cache instance by name using provided codec for both cache keys and values.
      <V> RSetReactive<V>  name)
      Returns transactional set instance by name.
      <V> RSetReactive<V>  name, Codec codec)
      Returns transactional set instance by name using provided codec for set objects.
      <V> RSetCacheReactive<V>  name)
      Returns transactional set-based cache instance by name.
      <V> RSetCacheReactive<V>  name, Codec codec)
      Returns transactional set-based cache instance by name.
      reactor.core.publisher.Mono<> rollback()
      Rollback all changes made on this transaction.

    • Method Detail

      • getBucket

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

      • getBucket

        <V>  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>  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>  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>  name)
        Returns transactional set instance by name.
        Type Parameters:
        V - type of value
        Parameters:
        name - - name of object
        Returns:
        Set object

      • getSet

        <V>  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>  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>  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>  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>  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

        reactor.core.publisher.Mono<> commit()
        Commits all changes made on this transaction.
        Returns:
        void

      • rollback

        reactor.core.publisher.Mono<> rollback()
        Rollback all changes made on this transaction.
        Returns:
        void