org.springframework.xd.dirt.server

Class AdminServer

java.lang.Object

org.springframework.xd.dirt.server.AdminServer

All Implemented Interfaces:

java.util.EventListener, org.springframework.beans.factory.DisposableBean, org.springframework.context.ApplicationListener<org.springframework.context.ApplicationEvent>, ContainerRepository

public class AdminServer
extends java.lang.Object
implements ContainerRepository, org.springframework.context.ApplicationListener<org.springframework.context.ApplicationEvent>, org.springframework.beans.factory.DisposableBean

Server that watches ZooKeeper for Container arrivals and departures from the XD cluster. Each AdminServer instance will attempt to request leadership, but at any given time only one AdminServer instance in the cluster will have leadership status. Those instances not elected will watch the Paths.ADMIN znode so that one of them will take over leadership if the leader admin closes or crashes.

Author:

Patrick Peralta, Mark Fisher

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	AdminServer.ContainerConverter Converts a ChildData node to a Container.

Constructor Summary

Constructors

Constructor and Description
AdminServer(ZooKeeperConnection zkConnection, StreamDefinitionRepository streamDefinitionRepository, ModuleDefinitionRepository moduleDefinitionRepository, ModuleOptionsMetadataResolver moduleOptionsMetadataResolver) Construct an AdminServer.

Method Summary

Methods

Modifier and Type	Method and Description
void	destroy()
java.util.Iterator<Container>	getContainerIterator() Return an Iterator over the available containers.
void	onApplicationEvent(org.springframework.context.ApplicationEvent event)

Methods inherited from class java.lang.Object

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

Constructor Detail

AdminServer

public AdminServer(ZooKeeperConnection zkConnection,
           StreamDefinitionRepository streamDefinitionRepository,
           ModuleDefinitionRepository moduleDefinitionRepository,
           ModuleOptionsMetadataResolver moduleOptionsMetadataResolver)

Construct an AdminServer.

Parameters:

zkConnection - ZooKeeper connection

streamDefinitionRepository - repository for streams

moduleDefinitionRepository - repository for modules

moduleOptionsMetadataResolver - resolver for module options metadata

Method Detail

onApplicationEvent

public void onApplicationEvent(org.springframework.context.ApplicationEvent event)

Specified by:

onApplicationEvent in interface org.springframework.context.ApplicationListener<org.springframework.context.ApplicationEvent>

getContainerIterator

public java.util.Iterator<Container> getContainerIterator()

Return an Iterator over the available containers.

Specified by:

getContainerIterator in interface ContainerRepository

Returns:

iterator over the available containers

destroy

public void destroy()

Specified by:

destroy in interface org.springframework.beans.factory.DisposableBean