Class DataServiceService
- java.lang.Object
-
- es.bsc.dataclay.communication.grpc.generated.dataservice.DataServiceGrpc.DataServiceImplBase
-
- es.bsc.dataclay.communication.grpc.services.dataservice.DataServiceService
-
- All Implemented Interfaces:
io.grpc.BindableService
public final class DataServiceService extends DataServiceGrpc.DataServiceImplBase
Implements all DataService GRPC methods.
-
-
Field Summary
Fields Modifier and Type Field Description protected static boolean
DEBUG_ENABLED
Indicates if debug is enabled.
-
Constructor Summary
Constructors Constructor Description DataServiceService(DataService thedataService)
Constructor
-
Method Summary
-
Methods inherited from class es.bsc.dataclay.communication.grpc.generated.dataservice.DataServiceGrpc.DataServiceImplBase
bindService
-
-
-
-
Constructor Detail
-
DataServiceService
public DataServiceService(DataService thedataService)
Constructor- Parameters:
thedataService
- Dataservice to process calls
-
-
Method Detail
-
initBackendID
public void initBackendID(DataserviceMessages.InitBackendIDRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
Description copied from class:DataServiceGrpc.DataServiceImplBase
Deployment
- Overrides:
initBackendID
in classDataServiceGrpc.DataServiceImplBase
-
deployMetaClasses
public void deployMetaClasses(DataserviceMessages.DeployMetaClassesRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
- Overrides:
deployMetaClasses
in classDataServiceGrpc.DataServiceImplBase
-
deployClasses
public void deployClasses(DataserviceMessages.DeployClassesRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
- Overrides:
deployClasses
in classDataServiceGrpc.DataServiceImplBase
-
enrichClass
public void enrichClass(DataserviceMessages.EnrichClassRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
- Overrides:
enrichClass
in classDataServiceGrpc.DataServiceImplBase
-
newPersistentInstance
public void newPersistentInstance(DataserviceMessages.NewPersistentInstanceRequest request, io.grpc.stub.StreamObserver<DataserviceMessages.NewPersistentInstanceResponse> responseObserver)
Storage Location.
- Overrides:
newPersistentInstance
in classDataServiceGrpc.DataServiceImplBase
-
storeObjects
public void storeObjects(DataserviceMessages.StoreObjectsRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
- Overrides:
storeObjects
in classDataServiceGrpc.DataServiceImplBase
-
getCopyOfObject
public void getCopyOfObject(DataserviceMessages.GetCopyOfObjectRequest request, io.grpc.stub.StreamObserver<DataserviceMessages.GetCopyOfObjectResponse> responseObserver)
- Overrides:
getCopyOfObject
in classDataServiceGrpc.DataServiceImplBase
-
updateObject
public void updateObject(DataserviceMessages.UpdateObjectRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
- Overrides:
updateObject
in classDataServiceGrpc.DataServiceImplBase
-
getObjects
public void getObjects(DataserviceMessages.GetObjectsRequest request, io.grpc.stub.StreamObserver<DataserviceMessages.GetObjectsResponse> responseObserver)
- Overrides:
getObjects
in classDataServiceGrpc.DataServiceImplBase
-
newVersion
public void newVersion(DataserviceMessages.NewVersionRequest request, io.grpc.stub.StreamObserver<DataserviceMessages.NewVersionResponse> responseObserver)
- Overrides:
newVersion
in classDataServiceGrpc.DataServiceImplBase
-
consolidateVersion
public void consolidateVersion(DataserviceMessages.ConsolidateVersionRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
- Overrides:
consolidateVersion
in classDataServiceGrpc.DataServiceImplBase
-
upsertObjects
public void upsertObjects(DataserviceMessages.UpsertObjectsRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
- Overrides:
upsertObjects
in classDataServiceGrpc.DataServiceImplBase
-
newReplica
public void newReplica(DataserviceMessages.NewReplicaRequest request, io.grpc.stub.StreamObserver<DataserviceMessages.NewReplicaResponse> responseObserver)
- Overrides:
newReplica
in classDataServiceGrpc.DataServiceImplBase
-
moveObjects
public void moveObjects(DataserviceMessages.MoveObjectsRequest request, io.grpc.stub.StreamObserver<DataserviceMessages.MoveObjectsResponse> responseObserver)
- Overrides:
moveObjects
in classDataServiceGrpc.DataServiceImplBase
-
removeObjects
public void removeObjects(DataserviceMessages.RemoveObjectsRequest request, io.grpc.stub.StreamObserver<DataserviceMessages.RemoveObjectsResponse> responseObserver)
- Overrides:
removeObjects
in classDataServiceGrpc.DataServiceImplBase
-
migrateObjectsToBackends
public void migrateObjectsToBackends(DataserviceMessages.MigrateObjectsRequest request, io.grpc.stub.StreamObserver<DataserviceMessages.MigrateObjectsResponse> responseObserver)
- Overrides:
migrateObjectsToBackends
in classDataServiceGrpc.DataServiceImplBase
-
getClassIDFromObjectInMemory
public void getClassIDFromObjectInMemory(DataserviceMessages.GetClassIDFromObjectInMemoryRequest request, io.grpc.stub.StreamObserver<DataserviceMessages.GetClassIDFromObjectInMemoryResponse> responseObserver)
- Overrides:
getClassIDFromObjectInMemory
in classDataServiceGrpc.DataServiceImplBase
-
makePersistent
public void makePersistent(DataserviceMessages.MakePersistentRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
- Overrides:
makePersistent
in classDataServiceGrpc.DataServiceImplBase
-
federate
public void federate(DataserviceMessages.FederateRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
- Overrides:
federate
in classDataServiceGrpc.DataServiceImplBase
-
unfederate
public void unfederate(DataserviceMessages.UnfederateRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
- Overrides:
unfederate
in classDataServiceGrpc.DataServiceImplBase
-
notifyFederation
public void notifyFederation(DataserviceMessages.NotifyFederationRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
- Overrides:
notifyFederation
in classDataServiceGrpc.DataServiceImplBase
-
notifyUnfederation
public void notifyUnfederation(DataserviceMessages.NotifyUnfederationRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
- Overrides:
notifyUnfederation
in classDataServiceGrpc.DataServiceImplBase
-
executeImplementation
public void executeImplementation(DataserviceMessages.ExecuteImplementationRequest request, io.grpc.stub.StreamObserver<DataserviceMessages.ExecuteImplementationResponse> responseObserver)
- Overrides:
executeImplementation
in classDataServiceGrpc.DataServiceImplBase
-
synchronize
public void synchronize(DataserviceMessages.SynchronizeRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
- Overrides:
synchronize
in classDataServiceGrpc.DataServiceImplBase
-
closeSessionInDS
public void closeSessionInDS(DataserviceMessages.CloseSessionInDSRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
- Overrides:
closeSessionInDS
in classDataServiceGrpc.DataServiceImplBase
-
updateRefs
public void updateRefs(DataserviceMessages.UpdateRefsRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
- Overrides:
updateRefs
in classDataServiceGrpc.DataServiceImplBase
-
getRetainedReferences
public void getRetainedReferences(CommonMessages.EmptyMessage request, io.grpc.stub.StreamObserver<DataserviceMessages.GetRetainedReferencesResponse> responseObserver)
- Overrides:
getRetainedReferences
in classDataServiceGrpc.DataServiceImplBase
-
cleanExecutionClassDirectory
public void cleanExecutionClassDirectory(CommonMessages.EmptyMessage request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
Others.
- Overrides:
cleanExecutionClassDirectory
in classDataServiceGrpc.DataServiceImplBase
-
closeDbHandler
public void closeDbHandler(CommonMessages.EmptyMessage request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
- Overrides:
closeDbHandler
in classDataServiceGrpc.DataServiceImplBase
-
shutDown
public void shutDown(CommonMessages.EmptyMessage request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
- Overrides:
shutDown
in classDataServiceGrpc.DataServiceImplBase
-
disconnectFromOthers
public void disconnectFromOthers(CommonMessages.EmptyMessage request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
- Overrides:
disconnectFromOthers
in classDataServiceGrpc.DataServiceImplBase
-
cleanCaches
public void cleanCaches(CommonMessages.EmptyMessage request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
Paraver.
- Overrides:
cleanCaches
in classDataServiceGrpc.DataServiceImplBase
-
activateTracing
public void activateTracing(DataserviceMessages.ActivateTracingRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
- Overrides:
activateTracing
in classDataServiceGrpc.DataServiceImplBase
-
deactivateTracing
public void deactivateTracing(CommonMessages.EmptyMessage request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
- Overrides:
deactivateTracing
in classDataServiceGrpc.DataServiceImplBase
-
getTraces
public void getTraces(CommonMessages.EmptyMessage request, io.grpc.stub.StreamObserver<CommonMessages.GetTracesResponse> responseObserver)
- Overrides:
getTraces
in classDataServiceGrpc.DataServiceImplBase
-
registerPendingObjects
public void registerPendingObjects(CommonMessages.EmptyMessage request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
- Overrides:
registerPendingObjects
in classDataServiceGrpc.DataServiceImplBase
-
exists
public void exists(DataserviceMessages.ExistsRequest request, io.grpc.stub.StreamObserver<DataserviceMessages.ExistsResponse> responseObserver)
- Overrides:
exists
in classDataServiceGrpc.DataServiceImplBase
-
existsInDB
public void existsInDB(DataserviceMessages.ExistsInDBRequest request, io.grpc.stub.StreamObserver<DataserviceMessages.ExistsInDBResponse> responseObserver)
- Overrides:
existsInDB
in classDataServiceGrpc.DataServiceImplBase
-
getNumObjects
public void getNumObjects(CommonMessages.EmptyMessage request, io.grpc.stub.StreamObserver<CommonMessages.GetNumObjectsResponse> responseObserver)
- Overrides:
getNumObjects
in classDataServiceGrpc.DataServiceImplBase
-
getNumObjectsInEE
public void getNumObjectsInEE(CommonMessages.EmptyMessage request, io.grpc.stub.StreamObserver<CommonMessages.GetNumObjectsResponse> responseObserver)
- Overrides:
getNumObjectsInEE
in classDataServiceGrpc.DataServiceImplBase
-
storeToDB
public void storeToDB(DataserviceMessages.StoreToDBRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
Description copied from class:DataServiceGrpc.DataServiceImplBase
Storage Location
- Overrides:
storeToDB
in classDataServiceGrpc.DataServiceImplBase
-
getFromDB
public void getFromDB(DataserviceMessages.GetFromDBRequest request, io.grpc.stub.StreamObserver<DataserviceMessages.GetFromDBResponse> responseObserver)
- Overrides:
getFromDB
in classDataServiceGrpc.DataServiceImplBase
-
updateToDB
public void updateToDB(DataserviceMessages.UpdateToDBRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
- Overrides:
updateToDB
in classDataServiceGrpc.DataServiceImplBase
-
deleteToDB
public void deleteToDB(DataserviceMessages.DeleteToDBRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
- Overrides:
deleteToDB
in classDataServiceGrpc.DataServiceImplBase
-
associateExecutionEnvironment
public void associateExecutionEnvironment(DataserviceMessages.AssociateExecutionEnvironmentRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
- Overrides:
associateExecutionEnvironment
in classDataServiceGrpc.DataServiceImplBase
-
detachObjectFromSession
public void detachObjectFromSession(DataserviceMessages.DetachObjectFromSessionRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
- Overrides:
detachObjectFromSession
in classDataServiceGrpc.DataServiceImplBase
-
deleteAlias
public void deleteAlias(DataserviceMessages.DeleteAliasRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
Description copied from class:DataServiceGrpc.DataServiceImplBase
Garbage collection
- Overrides:
deleteAlias
in classDataServiceGrpc.DataServiceImplBase
-
-