org.springframework.xd.dirt.module.redis

Class RedisModuleDependencyRepository

java.lang.Object

org.springframework.xd.dirt.module.redis.RedisModuleDependencyRepository

All Implemented Interfaces:

ModuleDependencyRepository

public class RedisModuleDependencyRepository
extends java.lang.Object
implements ModuleDependencyRepository

Redis implementation of ModuleDependencyRepository. Uses sets whose name is of the form dependencies.module.<type>:<name>.

Author:

Eric Bottard

Constructor Summary

Constructors

Constructor and Description
RedisModuleDependencyRepository(org.springframework.data.redis.core.RedisOperations<java.lang.String,java.lang.String> redisOperations)

Method Summary

Methods

Modifier and Type	Method and Description
void	delete(java.lang.String module, ModuleType type, java.lang.String target) Remove an atomic dependency from a module (composed or not) to some target (stream, or composed module).
java.util.Set<java.lang.String>	find(java.lang.String name, ModuleType type) Return the set of things that depend on the given module.
void	store(java.lang.String moduleName, ModuleType type, java.lang.String target) Store one atomic dependency from a module (composed or not) to some target (stream, or composed module).

Methods inherited from class java.lang.Object

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

Constructor Detail

RedisModuleDependencyRepository

public RedisModuleDependencyRepository(org.springframework.data.redis.core.RedisOperations<java.lang.String,java.lang.String> redisOperations)

Method Detail

store

public void store(java.lang.String moduleName,
         ModuleType type,
         java.lang.String target)

Description copied from interface: ModuleDependencyRepository

Store one atomic dependency from a module (composed or not) to some target (stream, or composed module).

Specified by:

store in interface ModuleDependencyRepository

delete

public void delete(java.lang.String module,
          ModuleType type,
          java.lang.String target)

Description copied from interface: ModuleDependencyRepository

Remove an atomic dependency from a module (composed or not) to some target (stream, or composed module).

Specified by:

delete in interface ModuleDependencyRepository

find

public java.util.Set<java.lang.String> find(java.lang.String name,
                                   ModuleType type)

Description copied from interface: ModuleDependencyRepository

Return the set of things that depend on the given module.

Specified by:

find in interface ModuleDependencyRepository

Returns:

a set of Strings of the form type:name, never null