Class ArRingKt
-
- All Implemented Interfaces:
public final class ArRingKt
-
-
Method Summary
Modifier and Type Method Description final static Longarring(RedisConnection $self, String key, Long size, String values)final static Longarring(RedisConnection $self, String key, Long size, Collection<String> values)final static Longarring(RedisConnectionPool $self, String key, Long size, String values)final static Longarring(RedisConnectionPool $self, String key, Long size, Collection<String> values)final static Unitarring(RedisPipelineBuilder $self, String key, Long size, String values, Function1<Long, Unit> onResult)final static Unitarring(RedisPipelineBuilder $self, String key, Long size, Collection<String> values, Function1<Long, Unit> onResult)Inserts values into a ring buffer of size elements: the insert cursor wraps around to 0 at size. final static LongarringBytes(RedisConnection $self, String key, Long size, ByteArray values)final static LongarringBytes(RedisConnection $self, String key, Long size, Collection<ByteArray> values)final static LongarringBytes(RedisConnectionPool $self, String key, Long size, ByteArray values)final static LongarringBytes(RedisConnectionPool $self, String key, Long size, Collection<ByteArray> values)final static UnitarringBytes(RedisPipelineBuilder $self, String key, Long size, ByteArray values, Function1<Long, Unit> onResult)final static UnitarringBytes(RedisPipelineBuilder $self, String key, Long size, Collection<ByteArray> values, Function1<Long, Unit> onResult)final static LongarringStreaming(RedisConnection $self, String key, Long size, Collection<StreamWithLength> values)final static LongarringStreaming(RedisConnectionPool $self, String key, Long size, Collection<StreamWithLength> values)final static UnitarringStreaming(RedisPipelineBuilder $self, String key, Long size, Collection<StreamWithLength> values, Function1<Long, Unit> onResult)-
-
Method Detail
-
arring
final static Long arring(RedisConnection $self, String key, Long size, Collection<String> values)
-
arring
final static Long arring(RedisConnectionPool $self, String key, Long size, Collection<String> values)
-
arring
final static Unit arring(RedisPipelineBuilder $self, String key, Long size, String values, Function1<Long, Unit> onResult)
-
arring
final static Unit arring(RedisPipelineBuilder $self, String key, Long size, Collection<String> values, Function1<Long, Unit> onResult)
Inserts values into a ring buffer of size elements: the insert cursor wraps around to 0 at size. An existing array with more than size elements is shrunk to size elements first.
- Parameters:
onResult-called with the index of the last inserted value
-
arringBytes
final static Long arringBytes(RedisConnection $self, String key, Long size, ByteArray values)
-
arringBytes
final static Long arringBytes(RedisConnection $self, String key, Long size, Collection<ByteArray> values)
-
arringBytes
final static Long arringBytes(RedisConnectionPool $self, String key, Long size, ByteArray values)
-
arringBytes
final static Long arringBytes(RedisConnectionPool $self, String key, Long size, Collection<ByteArray> values)
-
arringBytes
final static Unit arringBytes(RedisPipelineBuilder $self, String key, Long size, ByteArray values, Function1<Long, Unit> onResult)
-
arringBytes
final static Unit arringBytes(RedisPipelineBuilder $self, String key, Long size, Collection<ByteArray> values, Function1<Long, Unit> onResult)
-
arringStreaming
final static Long arringStreaming(RedisConnection $self, String key, Long size, Collection<StreamWithLength> values)
-
arringStreaming
final static Long arringStreaming(RedisConnectionPool $self, String key, Long size, Collection<StreamWithLength> values)
-
arringStreaming
final static Unit arringStreaming(RedisPipelineBuilder $self, String key, Long size, Collection<StreamWithLength> values, Function1<Long, Unit> onResult)
-
-
-
-