Class RedissonTransactionalSet<V>

    • Method Detail

      • expireAsync

        public RFuture<Boolean> expireAsync​(long timeToLive,
                                            TimeUnit timeUnit)
        Description copied from interface: RExpirableAsync
        Set a timeout for object in async mode. After the timeout has expired, the key will automatically be deleted.
        Specified by:
        expireAsync in interface RExpirableAsync
        Parameters:
        timeToLive - - timeout before object will be deleted
        timeUnit - - timeout time unit
        Returns:
        true if the timeout was set and false if not
      • expireAsync

        public RFuture<Boolean> expireAsync​(Instant timestamp)
        Description copied from interface: RExpirableAsync
        Set an expire date for object. When expire date comes the key will automatically be deleted.
        Specified by:
        expireAsync in interface RExpirableAsync
        Parameters:
        timestamp - - expire date
        Returns:
        true if the timeout was set and false if not
      • clearExpireAsync

        public RFuture<Boolean> clearExpireAsync()
        Description copied from interface: RExpirableAsync
        Clear an expire timeout or expire date for object in async mode. Object will not be deleted.
        Specified by:
        clearExpireAsync in interface RExpirableAsync
        Returns:
        true if the timeout was cleared and false if not
      • moveAsync

        public RFuture<Boolean> moveAsync​(int database)
        Description copied from interface: RObjectAsync
        Move object to another database in async mode
        Specified by:
        moveAsync in interface RObjectAsync
        Overrides:
        moveAsync in class RedissonObject
        Parameters:
        database - - number of Redis database
        Returns:
        true if key was moved false if not
      • migrateAsync

        public RFuture<Void> migrateAsync​(String host,
                                          int port,
                                          int database,
                                          long timeout)
        Description copied from interface: RObjectAsync
        Transfer object from source Redis instance to destination Redis instance in async mode
        Specified by:
        migrateAsync in interface RObjectAsync
        Overrides:
        migrateAsync in class RedissonObject
        Parameters:
        host - - destination host
        port - - destination port
        database - - destination database
        timeout - - maximum idle time in any moment of the communication with the destination instance in milliseconds
        Returns:
        void
      • mapReduce

        public <KOut,​VOut> RCollectionMapReduce<V,​KOut,​VOut> mapReduce()
        Description copied from interface: RSet
        Returns RMapReduce object associated with this object
        Specified by:
        mapReduce in interface RSet<V>
        Overrides:
        mapReduce in class RedissonSet<V>
        Type Parameters:
        KOut - output key
        VOut - output value
        Returns:
        MapReduce instance
      • getFairLock

        public RLock getFairLock​(V value)
        Description copied from interface: RSet
        Returns RLock instance associated with value
        Specified by:
        getFairLock in interface RSet<V>
        Overrides:
        getFairLock in class RedissonSet<V>
        Parameters:
        value - - set value
        Returns:
        RLock object
      • getSemaphore

        public RSemaphore getSemaphore​(V value)
        Description copied from interface: RSet
        Returns RSemaphore instance associated with value
        Specified by:
        getSemaphore in interface RSet<V>
        Overrides:
        getSemaphore in class RedissonSet<V>
        Parameters:
        value - - set value
        Returns:
        RSemaphore object
      • getLock

        public RLock getLock​(V value)
        Description copied from interface: RSet
        Returns lock instance associated with value
        Specified by:
        getLock in interface RSet<V>
        Overrides:
        getLock in class RedissonSet<V>
        Parameters:
        value - - set value
        Returns:
        RLock object
      • containsAsync

        public RFuture<Boolean> containsAsync​(Object o)
        Description copied from interface: RCollectionAsync
        Returns true if this collection contains encoded state of the specified element.
        Specified by:
        containsAsync in interface RCollectionAsync<V>
        Overrides:
        containsAsync in class RedissonSet<V>
        Parameters:
        o - element whose presence in this collection is to be tested
        Returns:
        true if this collection contains the specified element and false otherwise
      • removeAsync

        public RFuture<Boolean> removeAsync​(Object o)
        Description copied from interface: RCollectionAsync
        Removes a single instance of the specified element from this collection, if it is present.
        Specified by:
        removeAsync in interface RCollectionAsync<V>
        Overrides:
        removeAsync in class RedissonSet<V>
        Parameters:
        o - element to be removed from this collection, if present
        Returns:
        true if an element was removed as a result of this call
      • moveAsync

        public RFuture<Boolean> moveAsync​(String destination,
                                          V member)
        Description copied from interface: RSetAsync
        Move a member from this set to the given destination set in async mode.
        Specified by:
        moveAsync in interface RSetAsync<V>
        Overrides:
        moveAsync in class RedissonSet<V>
        Parameters:
        destination - the destination set
        member - the member to move
        Returns:
        true if the element is moved, false if the element is not a member of this set or no operation was performed
      • retainAllAsync

        public RFuture<Boolean> retainAllAsync​(Collection<?> c)
        Description copied from interface: RCollectionAsync
        Retains only the elements in this collection that are contained in the specified collection.
        Specified by:
        retainAllAsync in interface RCollectionAsync<V>
        Overrides:
        retainAllAsync in class RedissonSet<V>
        Parameters:
        c - collection containing elements to be retained in this collection
        Returns:
        true if this collection changed as a result of the call
      • removeAllAsync

        public RFuture<Boolean> removeAllAsync​(Collection<?> c)
        Description copied from interface: RCollectionAsync
        Removes all of this collection's elements that are also contained in the specified collection.
        Specified by:
        removeAllAsync in interface RCollectionAsync<V>
        Overrides:
        removeAllAsync in class RedissonSet<V>
        Parameters:
        c - collection containing elements to be removed from this collection
        Returns:
        true if this collection changed as a result of the call
      • unionAsync

        public RFuture<Integer> unionAsync​(String... names)
        Description copied from interface: RSetAsync
        Union sets specified by name and write to current set. If current set already exists, it is overwritten.
        Specified by:
        unionAsync in interface RSetAsync<V>
        Overrides:
        unionAsync in class RedissonSet<V>
        Parameters:
        names - - name of sets
        Returns:
        size of union
      • diffAsync

        public RFuture<Integer> diffAsync​(String... names)
        Description copied from interface: RSetAsync
        Diff sets specified by name and write to current set. If current set already exists, it is overwritten.
        Specified by:
        diffAsync in interface RSetAsync<V>
        Overrides:
        diffAsync in class RedissonSet<V>
        Parameters:
        names - - name of sets
        Returns:
        size of diff
      • readSortAsync

        public <T> RFuture<Collection<T>> readSortAsync​(String byPattern,
                                                        List<String> getPatterns,
                                                        SortOrder order,
                                                        int offset,
                                                        int count)
        Description copied from interface: RSortableAsync
        Read data in sorted view
        Specified by:
        readSortAsync in interface RSortableAsync<V>
        Overrides:
        readSortAsync in class RedissonSet<V>
        Type Parameters:
        T - object type
        Parameters:
        byPattern - that is used to generate the keys that are used for sorting
        getPatterns - that is used to load values by keys in sorted view
        order - for sorted data
        offset - of sorted data
        count - of sorted data
        Returns:
        sorted collection
      • readSortAlphaAsync

        public RFuture<Set<V>> readSortAlphaAsync​(String byPattern,
                                                  SortOrder order,
                                                  int offset,
                                                  int count)
        Description copied from interface: RSortableAsync
        Read data in sorted view lexicographically
        Specified by:
        readSortAlphaAsync in interface RSortableAsync<V>
        Overrides:
        readSortAlphaAsync in class RedissonSet<V>
        Parameters:
        byPattern - that is used to generate the keys that are used for sorting
        order - for sorted data
        offset - of sorted data
        count - of sorted data
        Returns:
        sorted collection lexicographically
      • readSortAlphaAsync

        public <T> RFuture<Collection<T>> readSortAlphaAsync​(String byPattern,
                                                             List<String> getPatterns,
                                                             SortOrder order)
        Description copied from interface: RSortableAsync
        Read data in sorted view lexicographically
        Specified by:
        readSortAlphaAsync in interface RSortableAsync<V>
        Overrides:
        readSortAlphaAsync in class RedissonSet<V>
        Type Parameters:
        T - object type
        Parameters:
        byPattern - that is used to generate the keys that are used for sorting
        getPatterns - that is used to load values by keys in sorted view
        order - for sorted data
        Returns:
        sorted collection lexicographically
      • readSortAlphaAsync

        public <T> RFuture<Collection<T>> readSortAlphaAsync​(String byPattern,
                                                             List<String> getPatterns,
                                                             SortOrder order,
                                                             int offset,
                                                             int count)
        Description copied from interface: RSortableAsync
        Read data in sorted view lexicographically
        Specified by:
        readSortAlphaAsync in interface RSortableAsync<V>
        Overrides:
        readSortAlphaAsync in class RedissonSet<V>
        Type Parameters:
        T - object type
        Parameters:
        byPattern - that is used to generate the keys that are used for sorting
        getPatterns - that is used to load values by keys in sorted view
        order - for sorted data
        offset - of sorted data
        count - of sorted data
        Returns:
        sorted collection lexicographically
      • sortToAsync

        public RFuture<Integer> sortToAsync​(String destName,
                                            String byPattern,
                                            List<String> getPatterns,
                                            SortOrder order,
                                            int offset,
                                            int count)
        Description copied from interface: RSortableAsync
        Sort data and store to destName list
        Specified by:
        sortToAsync in interface RSortableAsync<V>
        Overrides:
        sortToAsync in class RedissonSet<V>
        Parameters:
        destName - list object destination
        byPattern - that is used to generate the keys that are used for sorting
        getPatterns - that is used to load values by keys in sorted view
        order - for sorted data
        offset - of sorted data
        count - of sorted data
        Returns:
        length of sorted data
      • checkState

        protected void checkState()
      • expire

        public boolean expire​(long timeToLive,
                              TimeUnit timeUnit)
        Description copied from interface: RExpirable
        Set a timeout for object. After the timeout has expired, the key will automatically be deleted.
        Specified by:
        expire in interface RExpirable
        Parameters:
        timeToLive - - timeout before object will be deleted
        timeUnit - - timeout time unit
        Returns:
        true if the timeout was set and false if not
      • expireAt

        public boolean expireAt​(long timestamp)
        Description copied from interface: RExpirable
        Specified by:
        expireAt in interface RExpirable
        Parameters:
        timestamp - - expire date in milliseconds (Unix timestamp)
        Returns:
        true if the timeout was set and false if not
      • expire

        public boolean expire​(Instant instant)
        Description copied from interface: RExpirable
        Set an expire date for object. When expire date comes the key will automatically be deleted.
        Specified by:
        expire in interface RExpirable
        Parameters:
        instant - - expire date
        Returns:
        true if the timeout was set and false if not
      • clearExpire

        public boolean clearExpire()
        Description copied from interface: RExpirable
        Clear an expire timeout or expire date for object.
        Specified by:
        clearExpire in interface RExpirable
        Returns:
        true if timeout was removed false if object does not exist or does not have an associated timeout
      • remainTimeToLive

        public long remainTimeToLive()
        Description copied from interface: RExpirable
        Remaining time to live of Redisson object that has a timeout
        Specified by:
        remainTimeToLive in interface RExpirable
        Returns:
        time in milliseconds -2 if the key does not exist. -1 if the key exists but has no associated expire.
      • remainTimeToLiveAsync

        public RFuture<Long> remainTimeToLiveAsync()
        Description copied from interface: RExpirableAsync
        Remaining time to live of Redisson object that has a timeout
        Specified by:
        remainTimeToLiveAsync in interface RExpirableAsync
        Returns:
        time in milliseconds -2 if the key does not exist. -1 if the key exists but has no associated expire.