Package es.bsc.dataclay.communication.grpc.services.dataservice

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

Modifier and Type	Method	Description
void	activateTracing(DataserviceMessages.ActivateTracingRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
void	associateExecutionEnvironment(DataserviceMessages.AssociateExecutionEnvironmentRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
void	cleanCaches(CommonMessages.EmptyMessage request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)	Paraver.
void	cleanExecutionClassDirectory(CommonMessages.EmptyMessage request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)	Others.
void	closeDbHandler(CommonMessages.EmptyMessage request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
void	closeSessionInDS(DataserviceMessages.CloseSessionInDSRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
void	consolidateVersion(DataserviceMessages.ConsolidateVersionRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
void	deactivateTracing(CommonMessages.EmptyMessage request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
void	deleteAlias(DataserviceMessages.DeleteAliasRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)	Garbage collection
void	deleteToDB(DataserviceMessages.DeleteToDBRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
void	deployClasses(DataserviceMessages.DeployClassesRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
void	deployMetaClasses(DataserviceMessages.DeployMetaClassesRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
void	detachObjectFromSession(DataserviceMessages.DetachObjectFromSessionRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
void	disconnectFromOthers(CommonMessages.EmptyMessage request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
void	enrichClass(DataserviceMessages.EnrichClassRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
void	executeImplementation(DataserviceMessages.ExecuteImplementationRequest request, io.grpc.stub.StreamObserver<DataserviceMessages.ExecuteImplementationResponse> responseObserver)
void	exists(DataserviceMessages.ExistsRequest request, io.grpc.stub.StreamObserver<DataserviceMessages.ExistsResponse> responseObserver)
void	existsInDB(DataserviceMessages.ExistsInDBRequest request, io.grpc.stub.StreamObserver<DataserviceMessages.ExistsInDBResponse> responseObserver)
void	federate(DataserviceMessages.FederateRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
void	getClassIDFromObjectInMemory(DataserviceMessages.GetClassIDFromObjectInMemoryRequest request, io.grpc.stub.StreamObserver<DataserviceMessages.GetClassIDFromObjectInMemoryResponse> responseObserver)
void	getCopyOfObject(DataserviceMessages.GetCopyOfObjectRequest request, io.grpc.stub.StreamObserver<DataserviceMessages.GetCopyOfObjectResponse> responseObserver)
void	getFromDB(DataserviceMessages.GetFromDBRequest request, io.grpc.stub.StreamObserver<DataserviceMessages.GetFromDBResponse> responseObserver)
void	getNumObjects(CommonMessages.EmptyMessage request, io.grpc.stub.StreamObserver<CommonMessages.GetNumObjectsResponse> responseObserver)
void	getNumObjectsInEE(CommonMessages.EmptyMessage request, io.grpc.stub.StreamObserver<CommonMessages.GetNumObjectsResponse> responseObserver)
void	getObjects(DataserviceMessages.GetObjectsRequest request, io.grpc.stub.StreamObserver<DataserviceMessages.GetObjectsResponse> responseObserver)
void	getRetainedReferences(CommonMessages.EmptyMessage request, io.grpc.stub.StreamObserver<DataserviceMessages.GetRetainedReferencesResponse> responseObserver)
void	getTraces(CommonMessages.EmptyMessage request, io.grpc.stub.StreamObserver<CommonMessages.GetTracesResponse> responseObserver)
void	initBackendID(DataserviceMessages.InitBackendIDRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)	Deployment
void	makePersistent(DataserviceMessages.MakePersistentRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
void	migrateObjectsToBackends(DataserviceMessages.MigrateObjectsRequest request, io.grpc.stub.StreamObserver<DataserviceMessages.MigrateObjectsResponse> responseObserver)
void	moveObjects(DataserviceMessages.MoveObjectsRequest request, io.grpc.stub.StreamObserver<DataserviceMessages.MoveObjectsResponse> responseObserver)
void	newPersistentInstance(DataserviceMessages.NewPersistentInstanceRequest request, io.grpc.stub.StreamObserver<DataserviceMessages.NewPersistentInstanceResponse> responseObserver)	Storage Location.
void	newReplica(DataserviceMessages.NewReplicaRequest request, io.grpc.stub.StreamObserver<DataserviceMessages.NewReplicaResponse> responseObserver)
void	newVersion(DataserviceMessages.NewVersionRequest request, io.grpc.stub.StreamObserver<DataserviceMessages.NewVersionResponse> responseObserver)
void	notifyFederation(DataserviceMessages.NotifyFederationRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
void	notifyUnfederation(DataserviceMessages.NotifyUnfederationRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
void	registerPendingObjects(CommonMessages.EmptyMessage request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
void	removeObjects(DataserviceMessages.RemoveObjectsRequest request, io.grpc.stub.StreamObserver<DataserviceMessages.RemoveObjectsResponse> responseObserver)
void	shutDown(CommonMessages.EmptyMessage request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
void	storeObjects(DataserviceMessages.StoreObjectsRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
void	storeToDB(DataserviceMessages.StoreToDBRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)	Storage Location
void	synchronize(DataserviceMessages.SynchronizeRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
void	unfederate(DataserviceMessages.UnfederateRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
void	updateObject(DataserviceMessages.UpdateObjectRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
void	updateRefs(DataserviceMessages.UpdateRefsRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
void	updateToDB(DataserviceMessages.UpdateToDBRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)
void	upsertObjects(DataserviceMessages.UpsertObjectsRequest request, io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)

Methods inherited from class es.bsc.dataclay.communication.grpc.generated.dataservice.DataServiceGrpc.DataServiceImplBase

bindService

Methods inherited from class java.lang.Object

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

Field Detail

DEBUG_ENABLED

protected static final boolean DEBUG_ENABLED

Indicates if debug is enabled.

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 class DataServiceGrpc.DataServiceImplBase

deployMetaClasses

public void deployMetaClasses(DataserviceMessages.DeployMetaClassesRequest request,
                              io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)

Overrides:

deployMetaClasses in class DataServiceGrpc.DataServiceImplBase

deployClasses

public void deployClasses(DataserviceMessages.DeployClassesRequest request,
                          io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)

Overrides:

deployClasses in class DataServiceGrpc.DataServiceImplBase

enrichClass

public void enrichClass(DataserviceMessages.EnrichClassRequest request,
                        io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)

Overrides:

enrichClass in class DataServiceGrpc.DataServiceImplBase

newPersistentInstance

public void newPersistentInstance(DataserviceMessages.NewPersistentInstanceRequest request,
                                  io.grpc.stub.StreamObserver<DataserviceMessages.NewPersistentInstanceResponse> responseObserver)

 Storage Location.
 

Overrides:

newPersistentInstance in class DataServiceGrpc.DataServiceImplBase

storeObjects

public void storeObjects(DataserviceMessages.StoreObjectsRequest request,
                         io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)

Overrides:

storeObjects in class DataServiceGrpc.DataServiceImplBase

getCopyOfObject

public void getCopyOfObject(DataserviceMessages.GetCopyOfObjectRequest request,
                            io.grpc.stub.StreamObserver<DataserviceMessages.GetCopyOfObjectResponse> responseObserver)

Overrides:

getCopyOfObject in class DataServiceGrpc.DataServiceImplBase

updateObject

public void updateObject(DataserviceMessages.UpdateObjectRequest request,
                         io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)

Overrides:

updateObject in class DataServiceGrpc.DataServiceImplBase

getObjects

public void getObjects(DataserviceMessages.GetObjectsRequest request,
                       io.grpc.stub.StreamObserver<DataserviceMessages.GetObjectsResponse> responseObserver)

Overrides:

getObjects in class DataServiceGrpc.DataServiceImplBase

newVersion

public void newVersion(DataserviceMessages.NewVersionRequest request,
                       io.grpc.stub.StreamObserver<DataserviceMessages.NewVersionResponse> responseObserver)

Overrides:

newVersion in class DataServiceGrpc.DataServiceImplBase

consolidateVersion

public void consolidateVersion(DataserviceMessages.ConsolidateVersionRequest request,
                               io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)

Overrides:

consolidateVersion in class DataServiceGrpc.DataServiceImplBase

upsertObjects

public void upsertObjects(DataserviceMessages.UpsertObjectsRequest request,
                          io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)

Overrides:

upsertObjects in class DataServiceGrpc.DataServiceImplBase

newReplica

public void newReplica(DataserviceMessages.NewReplicaRequest request,
                       io.grpc.stub.StreamObserver<DataserviceMessages.NewReplicaResponse> responseObserver)

Overrides:

newReplica in class DataServiceGrpc.DataServiceImplBase

moveObjects

public void moveObjects(DataserviceMessages.MoveObjectsRequest request,
                        io.grpc.stub.StreamObserver<DataserviceMessages.MoveObjectsResponse> responseObserver)

Overrides:

moveObjects in class DataServiceGrpc.DataServiceImplBase

removeObjects

public void removeObjects(DataserviceMessages.RemoveObjectsRequest request,
                          io.grpc.stub.StreamObserver<DataserviceMessages.RemoveObjectsResponse> responseObserver)

Overrides:

removeObjects in class DataServiceGrpc.DataServiceImplBase

migrateObjectsToBackends

public void migrateObjectsToBackends(DataserviceMessages.MigrateObjectsRequest request,
                                     io.grpc.stub.StreamObserver<DataserviceMessages.MigrateObjectsResponse> responseObserver)

Overrides:

migrateObjectsToBackends in class DataServiceGrpc.DataServiceImplBase

getClassIDFromObjectInMemory

public void getClassIDFromObjectInMemory(DataserviceMessages.GetClassIDFromObjectInMemoryRequest request,
                                         io.grpc.stub.StreamObserver<DataserviceMessages.GetClassIDFromObjectInMemoryResponse> responseObserver)

Overrides:

getClassIDFromObjectInMemory in class DataServiceGrpc.DataServiceImplBase

makePersistent

public void makePersistent(DataserviceMessages.MakePersistentRequest request,
                           io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)

Overrides:

makePersistent in class DataServiceGrpc.DataServiceImplBase

federate

public void federate(DataserviceMessages.FederateRequest request,
                     io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)

Overrides:

federate in class DataServiceGrpc.DataServiceImplBase

unfederate

public void unfederate(DataserviceMessages.UnfederateRequest request,
                       io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)

Overrides:

unfederate in class DataServiceGrpc.DataServiceImplBase

notifyFederation

public void notifyFederation(DataserviceMessages.NotifyFederationRequest request,
                             io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)

Overrides:

notifyFederation in class DataServiceGrpc.DataServiceImplBase

notifyUnfederation

public void notifyUnfederation(DataserviceMessages.NotifyUnfederationRequest request,
                               io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)

Overrides:

notifyUnfederation in class DataServiceGrpc.DataServiceImplBase

executeImplementation

public void executeImplementation(DataserviceMessages.ExecuteImplementationRequest request,
                                  io.grpc.stub.StreamObserver<DataserviceMessages.ExecuteImplementationResponse> responseObserver)

Overrides:

executeImplementation in class DataServiceGrpc.DataServiceImplBase

synchronize

public void synchronize(DataserviceMessages.SynchronizeRequest request,
                        io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)

Overrides:

synchronize in class DataServiceGrpc.DataServiceImplBase

closeSessionInDS

public void closeSessionInDS(DataserviceMessages.CloseSessionInDSRequest request,
                             io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)

Overrides:

closeSessionInDS in class DataServiceGrpc.DataServiceImplBase

updateRefs

public void updateRefs(DataserviceMessages.UpdateRefsRequest request,
                       io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)

Overrides:

updateRefs in class DataServiceGrpc.DataServiceImplBase

getRetainedReferences

public void getRetainedReferences(CommonMessages.EmptyMessage request,
                                  io.grpc.stub.StreamObserver<DataserviceMessages.GetRetainedReferencesResponse> responseObserver)

Overrides:

getRetainedReferences in class DataServiceGrpc.DataServiceImplBase

cleanExecutionClassDirectory

public void cleanExecutionClassDirectory(CommonMessages.EmptyMessage request,
                                         io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)

 Others.
 

Overrides:

cleanExecutionClassDirectory in class DataServiceGrpc.DataServiceImplBase

closeDbHandler

public void closeDbHandler(CommonMessages.EmptyMessage request,
                           io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)

Overrides:

closeDbHandler in class DataServiceGrpc.DataServiceImplBase

shutDown

public void shutDown(CommonMessages.EmptyMessage request,
                     io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)

Overrides:

shutDown in class DataServiceGrpc.DataServiceImplBase

disconnectFromOthers

public void disconnectFromOthers(CommonMessages.EmptyMessage request,
                                 io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)

Overrides:

disconnectFromOthers in class DataServiceGrpc.DataServiceImplBase

cleanCaches

public void cleanCaches(CommonMessages.EmptyMessage request,
                        io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)

 Paraver.
 

Overrides:

cleanCaches in class DataServiceGrpc.DataServiceImplBase

activateTracing

public void activateTracing(DataserviceMessages.ActivateTracingRequest request,
                            io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)

Overrides:

activateTracing in class DataServiceGrpc.DataServiceImplBase

deactivateTracing

public void deactivateTracing(CommonMessages.EmptyMessage request,
                              io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)

Overrides:

deactivateTracing in class DataServiceGrpc.DataServiceImplBase

getTraces

public void getTraces(CommonMessages.EmptyMessage request,
                      io.grpc.stub.StreamObserver<CommonMessages.GetTracesResponse> responseObserver)

Overrides:

getTraces in class DataServiceGrpc.DataServiceImplBase

registerPendingObjects

public void registerPendingObjects(CommonMessages.EmptyMessage request,
                                   io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)

Overrides:

registerPendingObjects in class DataServiceGrpc.DataServiceImplBase

exists

public void exists(DataserviceMessages.ExistsRequest request,
                   io.grpc.stub.StreamObserver<DataserviceMessages.ExistsResponse> responseObserver)

Overrides:

exists in class DataServiceGrpc.DataServiceImplBase

existsInDB

public void existsInDB(DataserviceMessages.ExistsInDBRequest request,
                       io.grpc.stub.StreamObserver<DataserviceMessages.ExistsInDBResponse> responseObserver)

Overrides:

existsInDB in class DataServiceGrpc.DataServiceImplBase

getNumObjects

public void getNumObjects(CommonMessages.EmptyMessage request,
                          io.grpc.stub.StreamObserver<CommonMessages.GetNumObjectsResponse> responseObserver)

Overrides:

getNumObjects in class DataServiceGrpc.DataServiceImplBase

getNumObjectsInEE

public void getNumObjectsInEE(CommonMessages.EmptyMessage request,
                              io.grpc.stub.StreamObserver<CommonMessages.GetNumObjectsResponse> responseObserver)

Overrides:

getNumObjectsInEE in class DataServiceGrpc.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 class DataServiceGrpc.DataServiceImplBase

getFromDB

public void getFromDB(DataserviceMessages.GetFromDBRequest request,
                      io.grpc.stub.StreamObserver<DataserviceMessages.GetFromDBResponse> responseObserver)

Overrides:

getFromDB in class DataServiceGrpc.DataServiceImplBase

updateToDB

public void updateToDB(DataserviceMessages.UpdateToDBRequest request,
                       io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)

Overrides:

updateToDB in class DataServiceGrpc.DataServiceImplBase

deleteToDB

public void deleteToDB(DataserviceMessages.DeleteToDBRequest request,
                       io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)

Overrides:

deleteToDB in class DataServiceGrpc.DataServiceImplBase

associateExecutionEnvironment

public void associateExecutionEnvironment(DataserviceMessages.AssociateExecutionEnvironmentRequest request,
                                          io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)

Overrides:

associateExecutionEnvironment in class DataServiceGrpc.DataServiceImplBase

detachObjectFromSession

public void detachObjectFromSession(DataserviceMessages.DetachObjectFromSessionRequest request,
                                    io.grpc.stub.StreamObserver<CommonMessages.ExceptionInfo> responseObserver)

Overrides:

detachObjectFromSession in class DataServiceGrpc.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 class DataServiceGrpc.DataServiceImplBase