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 String
KEY_VALUE_OUTPUT_ARRAY_GLOOP_DOC
protected static String
KEY_VALUE_OUTPUT_GLOOP_DOC
protected static String
MAP_ARRAY_GLOOP_DOC
protected static String
MAP_OUTPUT_ARRAY_GLOOP_DOC
static String
SCAN_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 List
getKeyScanCursorKeys(KeyScanCursor keyScanCursor)
Gets a KeyScanCursor key liststatic GloopModel
getKeyValueAsGloopModel(KeyValue redisKeyValue)
static GloopModel
getKeyValuesAsGloopModel(List<KeyValue> redisKeyValues)
static GloopModel
getMapAsGloopModel(Map<Object,Object> map)
static Map
getMapScanCursorMap(MapScanCursor mapScanCursor)
Gets a MapScanCursor mapstatic GloopModel
getMapScanCursorMapAsGloopModel(MapScanCursor mapScanCursor)
Gets a MapScanCursor map, as a GloopModelstatic String
getScanCursorId(ScanCursor scanCursor)
Gets a scanCursor idstatic List<ScoredValue>
getScoredValueScanCursorValues(ScoredValueScanCursor scoredValueScanCursor)
Gets a ScoredValueScanCursor score liststatic GloopModel
getScoredValueScanCursorValuesAsGloopModel(ScoredValueScanCursor scoredValueScanCursor)
Gets a ScoredValueScanCursor score liststatic long
getStreamScanCursorCount(StreamScanCursor streamScanCursor)
Gets a StreamScanCursor countstatic List
getValueScanCursorValues(ValueScanCursor valueScanCursor)
Gets a ValueScanCursor value listprotected static ScanArgs
gloopModelToScanArgs(GloopModel scanArgs)
static boolean
isScanCursorFinished(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)
-
-