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

Class DataServiceGrpc.DataServiceStub

java.lang.Object

io.grpc.stub.AbstractStub<DataServiceGrpc.DataServiceStub>

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

Enclosing class:

DataServiceGrpc

public static final class DataServiceGrpc.DataServiceStub
extends io.grpc.stub.AbstractStub<DataServiceGrpc.DataServiceStub>

 Interface exported by the server.
 

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)
protected DataServiceGrpc.DataServiceStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
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 io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOption, withWaitForReady

Methods inherited from class java.lang.Object

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

Method Detail

build

protected DataServiceGrpc.DataServiceStub build(io.grpc.Channel channel,
                                                io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<DataServiceGrpc.DataServiceStub>

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)