ch.algotrader.util.health

Class HealthService

java.lang.Object

ch.algotrader.util.health.HealthService

All Implemented Interfaces:

LifecycleSubscriber, InitializingServiceI

public class HealthService
extends java.lang.Object
implements InitializingServiceI

This class is responsible for storing health updates from various components. Any component can get Consumer<HealthStatus> via getStatusUpdater(java.lang.String, java.lang.String) method - later it can submit its health status. Another way to propagate health status is to provide a function which will be periodically called to get the status - it is done via registerPull(java.lang.String, java.util.function.Supplier<Health>, long) method

We can request health status via @link #getHealthStatusMap} method.

Constructor Summary

Constructors

Constructor and Description
HealthService(java.util.function.Consumer<HealthStatusVO> healthStatusVoConsumer)

Method Summary

Modifier and Type	Method and Description
java.util.Map<java.lang.String,Health>	getHealthStatusMap() updates all health statuses (for pull functions, system stats like JVM, parent's status) and returns it as a map
java.util.function.Consumer<Health>	getStatusUpdaterAdapterReconciliation(ConnectorDescriptor connectorDescriptor) get health updater for reconciliation adapter
java.util.function.Consumer<Health>	getStatusUpdaterAdapterRestSession(ConnectorDescriptor connectorDescriptor) Deprecated.
java.util.function.Consumer<Health>	getStatusUpdaterAdapterSession(ConnectorDescriptor connectorDescriptor) Deprecated.
java.util.function.Consumer<Health>	getStatusUpdaterAdapterSession(java.lang.String name, ConnectorDescriptor connectorDescriptor) Deprecated.
void	init() Abstract initialization method that needs to be overwritten by the Service implementing this Interface
LifecyclePhase	initPhase()
void	registerPull(java.lang.String serviceName, java.util.function.Supplier<Health> healthCheckFunction, long checkHealthMinimumIntervalSec) instead of pushing updated health status via Consumer, we can register a pull function which will be called periodically.
void	updateConnectorServiceHealth(long accountId, DiagnosticEvent diagnosticEvent) Updates Health status of specific adapter's Capabilities basing on DiagnosticEvent

Methods inherited from class java.lang.Object

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

Methods inherited from interface ch.algotrader.service.InitializingServiceI

lifecycleSubscriptions, onLifecycleEvent

Methods inherited from interface ch.algotrader.lifecycle.LifecycleSubscriber

lifeCycleType

Constructor Detail

HealthService

public HealthService(java.util.function.Consumer<HealthStatusVO> healthStatusVoConsumer)

Method Detail

initPhase

public LifecyclePhase initPhase()

Specified by:

initPhase in interface InitializingServiceI

init

public void init()

Description copied from interface: InitializingServiceI

Abstract initialization method that needs to be overwritten by the Service implementing this Interface

Specified by:

init in interface InitializingServiceI

getStatusUpdaterAdapterSession

@Deprecated
public java.util.function.Consumer<Health> getStatusUpdaterAdapterSession(ConnectorDescriptor connectorDescriptor)

Deprecated.

get health updater for particular session and adapter.

Parameters:

connectorDescriptor -

Returns:

getStatusUpdaterAdapterSession

@Deprecated
public java.util.function.Consumer<Health> getStatusUpdaterAdapterSession(java.lang.String name,
                                                                                      ConnectorDescriptor connectorDescriptor)

Deprecated.

get health updater with specified name and adapter.

Parameters:

name -

connectorDescriptor -

Returns:

getStatusUpdaterAdapterRestSession

@Deprecated
public java.util.function.Consumer<Health> getStatusUpdaterAdapterRestSession(ConnectorDescriptor connectorDescriptor)

Deprecated.

get health updater for REST

Parameters:

connectorDescriptor -

Returns:

getStatusUpdaterAdapterReconciliation

public java.util.function.Consumer<Health> getStatusUpdaterAdapterReconciliation(ConnectorDescriptor connectorDescriptor)

get health updater for reconciliation adapter

Parameters:

connectorDescriptor -

Returns:

getHealthStatusMap

public java.util.Map<java.lang.String,Health> getHealthStatusMap()

updates all health statuses (for pull functions, system stats like JVM, parent's status) and returns it as a map

Returns:

map with updated health statuses

updateConnectorServiceHealth

public void updateConnectorServiceHealth(long accountId,
                                         DiagnosticEvent diagnosticEvent)

Updates Health status of specific adapter's Capabilities basing on DiagnosticEvent

Parameters:

accountId -

diagnosticEvent -

registerPull

public void registerPull(java.lang.String serviceName,
                         java.util.function.Supplier<Health> healthCheckFunction,
                         long checkHealthMinimumIntervalSec)

instead of pushing updated health status via Consumer, we can register a pull function which will be called periodically. It can be useful for tracking health status of external components .

Parameters:

serviceName -

healthCheckFunction -

checkHealthMinimumIntervalSec -