Package io.toro.martini.redis
Class RedisUtilMethods
- java.lang.Object
-
- io.toro.martini.redis.RedisUtilMethods
-
public class RedisUtilMethods extends Object
-
-
Field Summary
Fields Modifier and Type Field Description protected static StringKEY_VALUE_OUTPUT_ARRAY_GLOOP_DOCprotected static StringKEY_VALUE_OUTPUT_GLOOP_DOCprotected static StringMAP_ARRAY_GLOOP_DOCprotected static StringMAP_OUTPUT_ARRAY_GLOOP_DOCstatic StringSCAN_ARGS_GLOOP_DOC
-
Constructor Summary
Constructors Constructor Description RedisUtilMethods(io.toro.martini.database.DataSourceManager sourceManager)
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static Map<Object,Object>getGloopModelAsMap(GloopModel redisMap)static ListgetKeyScanCursorKeys(KeyScanCursor keyScanCursor)Gets a KeyScanCursor key liststatic GloopModelgetKeyValueAsGloopModel(KeyValue redisKeyValue)static GloopModelgetKeyValuesAsGloopModel(List<KeyValue> redisKeyValues)static GloopModelgetMapAsGloopModel(Map<Object,Object> map)static MapgetMapScanCursorMap(MapScanCursor mapScanCursor)Gets a MapScanCursor mapstatic GloopModelgetMapScanCursorMapAsGloopModel(MapScanCursor mapScanCursor)Gets a MapScanCursor map, as a GloopModelstatic StringgetScanCursorId(ScanCursor scanCursor)Gets a scanCursor idstatic List<ScoredValue>getScoredValueScanCursorValues(ScoredValueScanCursor scoredValueScanCursor)Gets a ScoredValueScanCursor score liststatic GloopModelgetScoredValueScanCursorValuesAsGloopModel(ScoredValueScanCursor scoredValueScanCursor)Gets a ScoredValueScanCursor score liststatic longgetStreamScanCursorCount(StreamScanCursor streamScanCursor)Gets a StreamScanCursor countstatic ListgetValueScanCursorValues(ValueScanCursor valueScanCursor)Gets a ValueScanCursor value listprotected static ScanArgsgloopModelToScanArgs(GloopModel scanArgs)static booleanisScanCursorFinished(ScanCursor scanCursor)Checks whether a StreamScanCursor is marked as finished
-
-
-
Field Detail
-
SCAN_ARGS_GLOOP_DOC
public static final String SCAN_ARGS_GLOOP_DOC
- See Also:
- Constant Field Values
-
KEY_VALUE_OUTPUT_ARRAY_GLOOP_DOC
protected static final String KEY_VALUE_OUTPUT_ARRAY_GLOOP_DOC
- See Also:
- Constant Field Values
-
KEY_VALUE_OUTPUT_GLOOP_DOC
protected static final String KEY_VALUE_OUTPUT_GLOOP_DOC
- See Also:
- Constant Field Values
-
MAP_ARRAY_GLOOP_DOC
protected static final String MAP_ARRAY_GLOOP_DOC
- See Also:
- Constant Field Values
-
MAP_OUTPUT_ARRAY_GLOOP_DOC
protected static final String MAP_OUTPUT_ARRAY_GLOOP_DOC
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
RedisUtilMethods
@Autowired RedisUtilMethods(io.toro.martini.database.DataSourceManager sourceManager)
-
-
Method Detail
-
gloopModelToScanArgs
protected static ScanArgs gloopModelToScanArgs(@GloopObjectParameter("scanArgs{\n limit:long:Limit the scan by count:false\n match::Set the match filter:false\n}\n") GloopModel scanArgs)
-
isScanCursorFinished
@GloopParameter(name="redisStreamScanCursorFinished") public static boolean isScanCursorFinished(@GloopParameter(allowNull=false) ScanCursor scanCursor)
Checks whether a StreamScanCursor is marked as finished- Parameters:
scanCursor- The StreamScanCursor to check- Returns:
- boolean stating whether the cursor has completed
-
getStreamScanCursorCount
@GloopParameter(name="redisStreamScanCursorCount") public static long getStreamScanCursorCount(@GloopParameter(allowNull=false) StreamScanCursor streamScanCursor)
Gets a StreamScanCursor count- Parameters:
streamScanCursor- The StreamScanCursor to get the count from- Returns:
- long stating the count of the cursor
-
getScanCursorId
@GloopParameter(name="redisStreamScanCursorId") public static String getScanCursorId(@GloopParameter(allowNull=false) ScanCursor scanCursor)
Gets a scanCursor id- Parameters:
scanCursor- The StreamScanCursor to get the id from- Returns:
- String stating the id of the cursor
-
getMapScanCursorMap
@GloopParameter(name="redisMapScanCursorMap") public static Map getMapScanCursorMap(@GloopParameter(allowNull=false) MapScanCursor mapScanCursor)
Gets a MapScanCursor map- Parameters:
mapScanCursor- The MapScanCursor to get the map from- Returns:
- map of the cursor
-
getMapScanCursorMapAsGloopModel
@GloopObjectParameter("output{\n redisMapCursorModel*{\n }\n}") public static GloopModel getMapScanCursorMapAsGloopModel(@GloopParameter(allowNull=false) MapScanCursor mapScanCursor)
Gets a MapScanCursor map, as a GloopModel- Parameters:
mapScanCursor- The MapScanCursor to get the map from as a @link GloopModel- Returns:
- map of the cursor
-
getKeyScanCursorKeys
@GloopParameter(name="redisKeyScanCursorKeys") public static List getKeyScanCursorKeys(@GloopParameter(allowNull=false) KeyScanCursor keyScanCursor)
Gets a KeyScanCursor key list- Parameters:
keyScanCursor- The KeyScanCursor to get the keys from- Returns:
- keys of the cursor
-
getValueScanCursorValues
@GloopParameter(name="redisValueScanCursorValues") public static List getValueScanCursorValues(@GloopParameter(allowNull=false) ValueScanCursor valueScanCursor)
Gets a ValueScanCursor value list- Parameters:
valueScanCursor- The ValueScanCursor to get the values from- Returns:
- values of the cursor
-
getScoredValueScanCursorValues
@GloopParameter(name="redisValueScanCursorValues") public static List<ScoredValue> getScoredValueScanCursorValues(@GloopParameter(allowNull=false) ScoredValueScanCursor scoredValueScanCursor)
Gets a ScoredValueScanCursor score list- Parameters:
scoredValueScanCursor- The ScoredValueScanCursor to get the scores from- Returns:
- scored values of the cursor
-
getScoredValueScanCursorValuesAsGloopModel
@GloopObjectParameter("output{\n scoredValues[]{\n value:object\n score:double\n }\n}") public static GloopModel getScoredValueScanCursorValuesAsGloopModel(@GloopParameter(allowNull=false) ScoredValueScanCursor scoredValueScanCursor)
Gets a ScoredValueScanCursor score list- Parameters:
scoredValueScanCursor- The ScoredValueScanCursor to get the scores from- Returns:
- scored values of the cursor
-
getKeyValueAsGloopModel
@GloopObjectParameter("output{\n redisKeyValue{\n key:object\n value:object\n }\n}") public static GloopModel getKeyValueAsGloopModel(@GloopParameter(allowNull=false) KeyValue redisKeyValue)
-
getKeyValuesAsGloopModel
@GloopObjectParameter("output{\n redisKeyValues[]{\n key:object\n value:object\n }\n}") public static GloopModel getKeyValuesAsGloopModel(@GloopParameter(allowNull=false) List<KeyValue> redisKeyValues)
-
getMapAsGloopModel
@GloopObjectParameter("output{\nredisMap[]{\n name:object\n value:object\n}\n}") public static GloopModel getMapAsGloopModel(@GloopParameter(allowNull=false) Map<Object,Object> map)
-
getGloopModelAsMap
public static Map<Object,Object> getGloopModelAsMap(@GloopObjectParameter("redisMap[]{\n name:object\n value:object\n}\n") GloopModel redisMap)
-
-