Class HealthServiceImpl

java.lang.Object

tech.skworks.tachyon.plugin.core.grpc.AbstractGrpcService

tech.skworks.tachyon.plugin.core.system.HealthServiceImpl

All Implemented Interfaces:

HealthService

public class HealthServiceImpl
extends AbstractGrpcService
implements HealthService

Project Tachyon Class GrpcSystemService

Handles core backend connectivity, gRPC ping telemetry, and autonomous adaptive health monitoring.

Since:

1.0.0-SNAPSHOT

Version:

2.0

Author:

Jimmy (vSKAH)

Field Summary

Fields inherited from class AbstractGrpcService

backendStubProvider, tachyonMetrics

Constructor Summary

Constructors

Constructor	Description
HealthServiceImpl(@Nullable TachyonMetrics tachyonMetrics, @NotNull BackendStubProvider backendStubProvider, @NotNull String serverName)

Method Summary

Modifier and Type	Method	Description
protected <T> void	handleGrpcExceptions(@NotNull String actionName, @NotNull io.grpc.StatusRuntimeException ex, CompletableFuture<T> future)
boolean	isHealthy()
CompletableFuture<PingResponse>	pingBackend()
void	shutdown()
void	startHealthMonitoring()

Methods inherited from class AbstractGrpcService

asyncCall, asyncRun, recordError, recordError, recordPlayerLockExhausted, recordPlayerLockRetry, startProfileLoadTimer, startTimer

Methods inherited from class Object

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

Constructor Details

HealthServiceImpl

public HealthServiceImpl(@Nullable
 @Nullable TachyonMetrics tachyonMetrics,
 @NotNull
 @NotNull BackendStubProvider backendStubProvider,
 @NotNull
 @NotNull String serverName)

Method Details

startHealthMonitoring

public void startHealthMonitoring()

isHealthy

public boolean isHealthy()

Specified by:

isHealthy in interface HealthService

pingBackend

public CompletableFuture<PingResponse> pingBackend()

Specified by:

pingBackend in interface HealthService

handleGrpcExceptions

protected <T> void handleGrpcExceptions(@NotNull
 @NotNull String actionName,
 @NotNull
 @NotNull io.grpc.StatusRuntimeException ex,
 CompletableFuture<T> future)

Specified by:

handleGrpcExceptions in class AbstractGrpcService

shutdown

public void shutdown()

Specified by:

shutdown in class AbstractGrpcService