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

Class DataServiceGrpc.DataServiceImplBase

java.lang.Object

es.bsc.dataclay.communication.grpc.generated.dataservice.DataServiceGrpc.DataServiceImplBase

All Implemented Interfaces:

io.grpc.BindableService

Direct Known Subclasses:

DataServiceService

Enclosing class:

DataServiceGrpc

public abstract static class DataServiceGrpc.DataServiceImplBase
extends Object
implements io.grpc.BindableService

 Interface exported by the server.
 

Constructor Summary

Constructors

Constructor	Description
DataServiceImplBase()

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)
io.grpc.ServerServiceDefinition	bindService()
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)	Execution Environment
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 java.lang.Object

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

Constructor Detail

DataServiceImplBase

public DataServiceImplBase()

Method Detail

initBackendID

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

 Deployment
 

associateExecutionEnvironment

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

deployMetaClasses

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

deployClasses

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

enrichClass

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

newPersistentInstance

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

 Execution Environment
 

storeObjects

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

getCopyOfObject

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

updateObject

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

getObjects

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

newVersion

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

consolidateVersion

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

upsertObjects

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

newReplica

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

moveObjects

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

removeObjects

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

migrateObjectsToBackends

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

getClassIDFromObjectInMemory

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

executeImplementation

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

makePersistent

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

federate

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

unfederate

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

notifyFederation

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

notifyUnfederation

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

exists

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

synchronize

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

storeToDB

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

 Storage Location
 

getFromDB

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

updateToDB

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

deleteToDB

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

existsInDB

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

cleanExecutionClassDirectory

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

 Others
 

closeDbHandler

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

shutDown

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

disconnectFromOthers

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

registerPendingObjects

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

cleanCaches

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

 Paraver
 

activateTracing

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

deactivateTracing

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

getTraces

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

deleteAlias

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

 Garbage collection
 

detachObjectFromSession

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

closeSessionInDS

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

updateRefs

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

getRetainedReferences

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

getNumObjects

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

getNumObjectsInEE

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

bindService

public final io.grpc.ServerServiceDefinition bindService()

Specified by:

bindService in interface io.grpc.BindableService