org.hobbit.controller.docker

Class ContainerStateObserverImpl

java.lang.Object

org.hobbit.controller.docker.ContainerStateObserverImpl

All Implemented Interfaces:

ContainerStateObserver

public class ContainerStateObserverImpl
extends Object
implements ContainerStateObserver

This class implements the ContainerStateObserver interface by starting a scheduled job that retrieves a list of containers and their status using the given ContainerManager. If a container has the status "exited" and can be found in the internal list of monitored containers, the ContainerTerminationCallback.notifyTermination(String, int) methods of all registered callbacks are called. Created by Timofey Ermilov on 01/09/16.

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	LOGGER
private ContainerManager	manager The ContainerManager class that is used to retrieve information about containers.
private List<String>	monitoredContainers Internal list of monitored Docker containers.
private int	repeatInterval The time interval in which the checking of containers is performed.
private List<ContainerTerminationCallback>	terminationCallbacks List of termination callbacks that are called if one of the monitored containers was terminated.
private Timer	timer The Timer used to regularly check the state of container.
private static List<String>	unfinishedTaskStates

Constructor Summary

Constructors

Constructor and Description
ContainerStateObserverImpl(ContainerManager manager, int repeatInterval) Constructor.

Method Summary

Modifier and Type	Method and Description
void	addObservedContainer(String containerId) Adds the container with the given container Id to the list of observed containers.
void	addTerminationCallback(ContainerTerminationCallback callback) Adds the callback that will be notified using ContainerTerminationCallback.notifyTermination(String, int)
List<String>	getObservedContainers() Returns the list of observed containers.
void	removedObservedContainer(String containerId) Removes the container with the given container Id from the list of observed containers.
void	removeTerminationCallback(ContainerTerminationCallback callback) Removes the callback that will be notified using ContainerTerminationCallback.notifyTermination(String, int)
void	startObserving() Start observing the state of containers
void	stopObserving() Stop observing the state of containers

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

private static final org.slf4j.Logger LOGGER

unfinishedTaskStates

private static final List<String> unfinishedTaskStates

monitoredContainers

private List<String> monitoredContainers

Internal list of monitored Docker containers.

terminationCallbacks

private List<ContainerTerminationCallback> terminationCallbacks

List of termination callbacks that are called if one of the monitored containers was terminated.

manager

private ContainerManager manager

The ContainerManager class that is used to retrieve information about containers.

repeatInterval

private int repeatInterval

The time interval in which the checking of containers is performed.

timer

private Timer timer

The Timer used to regularly check the state of container.

Constructor Detail

ContainerStateObserverImpl

public ContainerStateObserverImpl(ContainerManager manager,
                                  int repeatInterval)

Constructor.

Parameters:

manager - The ContainerManager class that is used to retrieve information about containers.

repeatInterval - The time interval in which the checking of containers is performed.

Method Detail

startObserving

public void startObserving()

Description copied from interface: ContainerStateObserver

Start observing the state of containers

Specified by:

startObserving in interface ContainerStateObserver

stopObserving

public void stopObserving()

Description copied from interface: ContainerStateObserver

Stop observing the state of containers

Specified by:

stopObserving in interface ContainerStateObserver

addTerminationCallback

public void addTerminationCallback(ContainerTerminationCallback callback)

Description copied from interface: ContainerStateObserver

Adds the callback that will be notified using ContainerTerminationCallback.notifyTermination(String, int)

Specified by:

addTerminationCallback in interface ContainerStateObserver

Parameters:

callback - the class that should be called if a container terminates

removeTerminationCallback

public void removeTerminationCallback(ContainerTerminationCallback callback)

Description copied from interface: ContainerStateObserver

Removes the callback that will be notified using ContainerTerminationCallback.notifyTermination(String, int)

Specified by:

removeTerminationCallback in interface ContainerStateObserver

Parameters:

callback - the class that should be called if a container terminates

addObservedContainer

public void addObservedContainer(String containerId)

Description copied from interface: ContainerStateObserver

Adds the container with the given container Id to the list of observed containers.

Specified by:

addObservedContainer in interface ContainerStateObserver

Parameters:

containerId - the Id of the container that should be observed

removedObservedContainer

public void removedObservedContainer(String containerId)

Description copied from interface: ContainerStateObserver

Removes the container with the given container Id from the list of observed containers.

Specified by:

removedObservedContainer in interface ContainerStateObserver

Parameters:

containerId - the Id of the container that should be removed

getObservedContainers

public List<String> getObservedContainers()

Description copied from interface: ContainerStateObserver

Returns the list of observed containers.

Specified by:

getObservedContainers in interface ContainerStateObserver

Returns:

the list of containers that should be observer