Class AbstractGrpcService

java.lang.Object

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

Direct Known Subclasses:

GrpcAuditService, GrpcPlayerDataService, GrpcPlayerSessionService, GrpcSnapshotService, GrpcSystemService

public abstract class AbstractGrpcService
extends Object

Project Tachyon Class AbstractGrpcService

Since:

1.0.0-SNAPSHOT

Version:

1.0

Author:

Jimmy (vSKAH) - 13/04/2026

Field Summary

Fields

Modifier and Type	Field	Description
protected final @NotNull BackendStubProvider	backendStubProvider
protected final @Nullable TachyonMetrics	tachyonMetrics

Constructor Summary

Constructors

Constructor	Description
AbstractGrpcService(@Nullable TachyonMetrics tachyonMetrics, @NotNull BackendStubProvider backendStubProvider)

Method Summary

Modifier and Type	Method	Description
protected <T> CompletableFuture<T>	asyncCall(Executor executor, TachyonLogger logger, String actionName, Supplier<T> grpcCall)
protected CompletableFuture<Void>	asyncRun(Executor executor, TachyonLogger logger, String actionName, Runnable grpcCall)
protected abstract <T> void	handleGrpcExceptions(@NotNull String actionName, @NotNull tech.skworks.tachyon.libs.io.grpc.StatusRuntimeException ex, CompletableFuture<T> future)
void	recordError(String method, Exception e)
void	recordError(String method, String errorCode)
abstract void	shutdown()
AutoCloseable	startTimer(String method)

Methods inherited from class Object

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

Field Details

tachyonMetrics

@Nullable
protected final @Nullable TachyonMetrics tachyonMetrics

backendStubProvider

@NotNull
protected final @NotNull BackendStubProvider backendStubProvider

Constructor Details

AbstractGrpcService

public AbstractGrpcService(@Nullable
 @Nullable TachyonMetrics tachyonMetrics,
 @NotNull
 @NotNull BackendStubProvider backendStubProvider)

Method Details

startTimer

public AutoCloseable startTimer(String method)

recordError

public void recordError(String method,
 Exception e)

recordError

public void recordError(String method,
 String errorCode)

handleGrpcExceptions

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

asyncCall

protected <T> CompletableFuture<T> asyncCall(Executor executor,
 TachyonLogger logger,
 String actionName,
 Supplier<T> grpcCall)

asyncRun

protected CompletableFuture<Void> asyncRun(Executor executor,
 TachyonLogger logger,
 String actionName,
 Runnable grpcCall)

shutdown

public abstract void shutdown()