Class AbstractGrpcService

java.lang.Object

tech.skworks.tachyon.plugin.internal.util.AbstractGrpcService

Direct Known Subclasses:

GrpcComponentService, GrpcSnapshotService, HeartBeatService

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 GrpcClientManager	grpcClientManager
protected final @Nullable TachyonMetrics	tachyonMetrics

Constructor Summary

Constructors

Constructor	Description
AbstractGrpcService(@Nullable TachyonMetrics tachyonMetrics, GrpcClientManager grpcClientManager)

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(String actionName, tech.skworks.tachyon.libs.io.grpc.StatusRuntimeException ex, CompletableFuture<T> future)
void	recordError(String method, Exception e)
void	recordError(String method, String errorCode)
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

grpcClientManager

protected final GrpcClientManager grpcClientManager

Constructor Details

AbstractGrpcService

public AbstractGrpcService(@Nullable
 @Nullable TachyonMetrics tachyonMetrics,
 GrpcClientManager grpcClientManager)

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(String actionName,
 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)