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 and 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 and Description
RedisUtilMethods(DataSourceManager dataSourceManager)

Method Summary

Modifier and Type	Method and Description
static Map<Object,Object>	getGloopModelAsMap(GloopModel redisMap)
static List	getKeyScanCursorKeys(KeyScanCursor keyScanCursor) Gets a KeyScanCursor key list
static 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 map
static GloopModel	getMapScanCursorMapAsGloopModel(MapScanCursor mapScanCursor) Gets a MapScanCursor map, as a GloopModel
static String	getScanCursorId(ScanCursor scanCursor) Gets a scanCursor id
static List<ScoredValue>	getScoredValueScanCursorValues(ScoredValueScanCursor scoredValueScanCursor) Gets a ScoredValueScanCursor score list
static GloopModel	getScoredValueScanCursorValuesAsGloopModel(ScoredValueScanCursor scoredValueScanCursor) Gets a ScoredValueScanCursor score list
static long	getStreamScanCursorCount(StreamScanCursor streamScanCursor) Gets a StreamScanCursor count
static List	getValueScanCursorValues(ValueScanCursor valueScanCursor) Gets a ValueScanCursor value list
protected static ScanArgs	gloopModelToScanArgs(GloopModel scanArgs)
static boolean	isScanCursorFinished(ScanCursor scanCursor) Checks whether a StreamScanCursor is marked as finished

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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(DataSourceManager dataSourceManager)

Method Detail

gloopModelToScanArgs

protected static ScanArgs gloopModelToScanArgs(@GloopObjectParameter(value="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(value="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(value="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(value="output{\n  redisKeyValue{\n    key:object\n    value:object\n  }\n}")
public static GloopModel getKeyValueAsGloopModel(@GloopParameter(allowNull=false)
                                                                                                                                                    KeyValue redisKeyValue)

getKeyValuesAsGloopModel

@GloopObjectParameter(value="output{\n  redisKeyValues[]{\n    key:object\n    value:object\n  }\n}")
public static GloopModel getKeyValuesAsGloopModel(@GloopParameter(allowNull=false)
                                                                                                                                                        List<KeyValue> redisKeyValues)

getMapAsGloopModel

@GloopObjectParameter(value="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(value="redisMap[]{\n  name:object\n  value:object\n}\n")
                                                    GloopModel redisMap)