Package ch.rswk.meta.engine

Class EngineRuntime

java.lang.Object

ch.rswk.meta.engine.EngineRuntime

All Implemented Interfaces:

Executor

@Singleton
public class EngineRuntime
extends Object
implements Executor

EngineRuntime provides executor services, ServiceManager for service lifecycle, centralized access to Metric, Health-Check and AlertRegistry.

Implements Executor to provide convenience to submit and handle async tasks. See ListenableFuture.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	EngineRuntime.AbstractConfigWatcher<T>
static final record	EngineRuntime.AsyncCacheStatsGaugeSet
static final record	EngineRuntime.CacheStatsGaugeSet
static final record	EngineRuntime.ConfigWatcherNotification
private static class	EngineRuntime.CpuGaugeSet
private static class	EngineRuntime.DiskSpaceHealthCheck
static final record	EngineRuntime.EngineRuntimeConfig
static interface	EngineRuntime.FileWatcher
private static class	EngineRuntime.FreeDiskSpaceGaugeSet
private class	EngineRuntime.RuntimeHealthCheck

Field Summary

Fields

Modifier and Type	Field	Description
private final AlertRegistry	alertRegistry
private final EngineRuntime.EngineRuntimeConfig	config
private final com.google.common.eventbus.EventBus	eventBus
private final com.google.common.util.concurrent.ListeningExecutorService	executor
private final com.codahale.metrics.health.HealthCheckRegistry	healthCheckRegistry
private static final org.slf4j.Logger	LOG
private final com.codahale.metrics.MetricRegistry	metricRegistry
private boolean	running
private static final String	RUNTIME_METRIC_PREFIX
private final ScheduledTasks	scheduledTasks
private final com.github.benmanes.caffeine.cache.Scheduler	scheduler
private static final Collector<CharSequence,?,String>	SERVICE_NAME_JOINER
private final javax.inject.Provider<com.google.common.util.concurrent.ServiceManager>	serviceManagerProvider
private OffsetDateTime	startDateTime
private static final Predicate<com.google.common.util.concurrent.Service.State>	UNHEALTHY_SERVICE_STATES
static final Duration	WATCH_SCHEDULE
private final Map<String,EngineRuntime.FileWatcher>	watchersByFileName
private final WatchService	watchService

Constructor Summary

Constructors

Constructor

Description

EngineRuntime(AlertRegistry alertRegistry, EngineRuntime.EngineRuntimeConfig config, com.google.common.eventbus.EventBus eventBus, com.google.common.util.concurrent.ListeningExecutorService executor, com.codahale.metrics.health.HealthCheckRegistry healthCheckRegistry, com.codahale.metrics.MetricRegistry metricRegistry, javax.inject.Provider<com.google.common.util.concurrent.ServiceManager> serviceManagerProvider, Set<EngineRuntime.FileWatcher> watchers)

Method Summary

Modifier and Type	Method	Description
AlertRegistry	alertRegistry()
private static boolean	awaitServices(Consumer<com.google.common.util.concurrent.Service> await, com.google.common.util.concurrent.Service... services)
boolean	awaitServicesRunning(com.google.common.util.concurrent.Service... services)
boolean	awaitServicesTerminated(com.google.common.util.concurrent.Service... services)
static void	cancelFuture(@Nullable Future<?> f)
private void	checkForFileChanges()
com.google.common.eventbus.EventBus	eventBus()
void	execute(Runnable command)
com.fasterxml.jackson.databind.node.ObjectNode	getServiceInfo()
private String	getServiceName(Object service)
<T> List<T>	getServices(Class<T> type)
Set<String>	getUnhealthyService()
Duration	getUptime()
private static WatchService	getWatchService()
com.codahale.metrics.health.HealthCheckRegistry	healthCheckRegistry()
boolean	isHealthy()
boolean	isServiceManagerHealthy()
com.codahale.metrics.MetricRegistry	metricRegistry()
static com.codahale.metrics.health.HealthCheckRegistry	newHealthCheckRegistry()
static com.codahale.metrics.MetricRegistry	newMetricRegistry()
private static void	putStatsMetrics(Map<String,com.codahale.metrics.Metric> metrics, com.github.benmanes.caffeine.cache.stats.CacheStats stats)
void	registerFileWatcher(EngineRuntime.FileWatcher watcher)
ScheduledTasks	scheduledTasks()
com.github.benmanes.caffeine.cache.Scheduler	scheduler()
void	shutDown()
void	shutdownAndAwaitTermination(ExecutorService executor)
void	startUp()
void	submit(Runnable task)
<T> com.google.common.util.concurrent.ListenableFuture<T>	submit(Callable<T> task)

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

WATCH_SCHEDULE

public static final Duration WATCH_SCHEDULE

RUNTIME_METRIC_PREFIX

private static final String RUNTIME_METRIC_PREFIX

See Also:

• Constant Field Values

SERVICE_NAME_JOINER

private static final Collector<CharSequence,?,String> SERVICE_NAME_JOINER

UNHEALTHY_SERVICE_STATES

private static final Predicate<com.google.common.util.concurrent.Service.State> UNHEALTHY_SERVICE_STATES

alertRegistry

private final AlertRegistry alertRegistry

config

private final EngineRuntime.EngineRuntimeConfig config

eventBus

private final com.google.common.eventbus.EventBus eventBus

executor

private final com.google.common.util.concurrent.ListeningExecutorService executor

healthCheckRegistry

private final com.codahale.metrics.health.HealthCheckRegistry healthCheckRegistry

metricRegistry

private final com.codahale.metrics.MetricRegistry metricRegistry

scheduledTasks

private final ScheduledTasks scheduledTasks

scheduler

private final com.github.benmanes.caffeine.cache.Scheduler scheduler

serviceManagerProvider

private final javax.inject.Provider<com.google.common.util.concurrent.ServiceManager> serviceManagerProvider

watchService

private final WatchService watchService

watchersByFileName

private final Map<String,EngineRuntime.FileWatcher> watchersByFileName

running

private volatile boolean running

startDateTime

private OffsetDateTime startDateTime

Constructor Details

EngineRuntime

@Inject
public EngineRuntime(AlertRegistry alertRegistry,
 EngineRuntime.EngineRuntimeConfig config,
 com.google.common.eventbus.EventBus eventBus,
 com.google.common.util.concurrent.ListeningExecutorService executor,
 com.codahale.metrics.health.HealthCheckRegistry healthCheckRegistry,
 com.codahale.metrics.MetricRegistry metricRegistry,
 javax.inject.Provider<com.google.common.util.concurrent.ServiceManager> serviceManagerProvider,
 Set<EngineRuntime.FileWatcher> watchers)

Method Details

registerFileWatcher

public void registerFileWatcher(EngineRuntime.FileWatcher watcher)

alertRegistry

public AlertRegistry alertRegistry()

awaitServicesRunning

public boolean awaitServicesRunning(com.google.common.util.concurrent.Service... services)

awaitServices

private static boolean awaitServices(Consumer<com.google.common.util.concurrent.Service> await,
 com.google.common.util.concurrent.Service... services)

awaitServicesTerminated

public boolean awaitServicesTerminated(com.google.common.util.concurrent.Service... services)

cancelFuture

public static void cancelFuture(@Nullable Future<?> f)

eventBus

public com.google.common.eventbus.EventBus eventBus()

execute

public void execute(Runnable command)

Specified by:

execute in interface Executor

getServiceInfo

public com.fasterxml.jackson.databind.node.ObjectNode getServiceInfo()

getUptime

public Duration getUptime()

getServices

public <T> List<T> getServices(Class<T> type)

getServiceName

private String getServiceName(Object service)

getUnhealthyService

public Set<String> getUnhealthyService()

getWatchService

private static WatchService getWatchService()

healthCheckRegistry

public com.codahale.metrics.health.HealthCheckRegistry healthCheckRegistry()

isHealthy

public boolean isHealthy()

isServiceManagerHealthy

public boolean isServiceManagerHealthy()

metricRegistry

public com.codahale.metrics.MetricRegistry metricRegistry()

newHealthCheckRegistry

public static com.codahale.metrics.health.HealthCheckRegistry newHealthCheckRegistry()

newMetricRegistry

public static com.codahale.metrics.MetricRegistry newMetricRegistry()

putStatsMetrics

private static void putStatsMetrics(Map<String,com.codahale.metrics.Metric> metrics,
 com.github.benmanes.caffeine.cache.stats.CacheStats stats)

scheduledTasks

public ScheduledTasks scheduledTasks()

scheduler

public com.github.benmanes.caffeine.cache.Scheduler scheduler()

startUp

public void startUp()

shutDown

public void shutDown()

shutdownAndAwaitTermination

public void shutdownAndAwaitTermination(ExecutorService executor)

checkForFileChanges

private void checkForFileChanges()

submit

public <T>
com.google.common.util.concurrent.ListenableFuture<T> submit(Callable<T> task)

See Also:

• ListeningExecutorService.submit(Callable)

submit

public void submit(Runnable task)

See Also:

• ListeningExecutorService.submit(Runnable)