org.thales.punch.platform.api

Interface IApplicationExitController

All Superinterfaces:

AutoCloseable

public interface IApplicationExitController
extends AutoCloseable

This interface is used to be prompted about punch application that expresses their willingness to stop.

Behind the scene, Kafka is (typically) used for this. An application (for example a spark or punch light stream punchline) once completed instead of exiting, send an exit wish to a platform topic. In turn this interface let some controller be notified, and request a clean exit of that application.

This interface is used in the dag management.

Author:

dimi

Method Summary

Modifier and Type	Method and Description
List<IApplication>	getTerminatedApplications(List<IApplication> list, Duration timeout)

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

getTerminatedApplications

List<IApplication> getTerminatedApplications(List<IApplication> list,
                                             Duration timeout)

Parameters:

list - a list of known applications

timeout - the delay used to read and possibly wait for the kafka queue

Returns:

these applications that expressed their wish to exit. Thes apps are registered with the corresponding wish for you to retrieve it.