org.springframework.xd.dirt.module.store

Class ZooKeeperModuleDependencyRepository

java.lang.Object

org.springframework.xd.dirt.module.store.ZooKeeperModuleDependencyRepository

All Implemented Interfaces:

ModuleDependencyRepository

public class ZooKeeperModuleDependencyRepository
extends java.lang.Object
implements ModuleDependencyRepository

ZooKeeper based implementation of ModuleDependencyRepository that writes each dependency to a node, such as: /xd/modules/[moduletype]/[modulename]/dependencies/[target].

Author:

Mark Fisher, David Turanski

Constructor Summary

Constructors

Constructor and Description
ZooKeeperModuleDependencyRepository(ZooKeeperConnection connection)

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

ZooKeeperModuleDependencyRepository

@Autowired
public ZooKeeperModuleDependencyRepository(ZooKeeperConnection connection)

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

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

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