com.spotify.flo.context

Interface InstrumentedContext.Listener

All Superinterfaces:

AutoCloseable, Closeable, Serializable

All Known Implementing Classes:

LoggingListener

Enclosing class:

InstrumentedContext

public static interface InstrumentedContext.Listener
extends Closeable, Serializable

A listener for instrumented evaluation. See InstrumentedContext for more details.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	InstrumentedContext.Listener.Phase The different phases of task evaluation.

Method Summary

Modifier and Type	Method and Description
default void	close() Called to close resources or connections used by the implementing class.
default void	meta(TaskId task, Map<String,String> data) Called to report some piece of task metadata.
void	status(TaskId task, InstrumentedContext.Listener.Phase phase) Called when a task starts and finished it's evaluation.
void	task(Task<?> task) Called when a Task is discovered.

Method Detail

task

void task(Task<?> task)

Called when a Task is discovered.

Parameters:

task - The discovered task object

status

void status(TaskId task,
            InstrumentedContext.Listener.Phase phase)

Called when a task starts and finished it's evaluation. This will be called exactly twice per evaluation of a task.

Parameters:

task - The task that is being evaluated

phase - The phase of evaluation

meta

default void meta(TaskId task,
                  Map<String,String> data)

Called to report some piece of task metadata.

Parameters:

task - The task that is being evaluated

data - The key-value metadata

close

default void close()
            throws IOException

Called to close resources or connections used by the implementing class.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException