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

Class DataServiceGrpc.DataServiceFutureStub

java.lang.Object

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

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

Enclosing class:

DataServiceGrpc

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

 Interface exported by the server.
 

Method Summary

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

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.DataServiceFutureStub build(io.grpc.Channel channel,
                                                      io.grpc.CallOptions callOptions)

Specified by:

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

initBackendID

public com.google.common.util.concurrent.ListenableFuture<CommonMessages.ExceptionInfo> initBackendID(DataserviceMessages.InitBackendIDRequest request)

 Deployment
 

associateExecutionEnvironment

public com.google.common.util.concurrent.ListenableFuture<CommonMessages.ExceptionInfo> associateExecutionEnvironment(DataserviceMessages.AssociateExecutionEnvironmentRequest request)

deployMetaClasses

public com.google.common.util.concurrent.ListenableFuture<CommonMessages.ExceptionInfo> deployMetaClasses(DataserviceMessages.DeployMetaClassesRequest request)

deployClasses

public com.google.common.util.concurrent.ListenableFuture<CommonMessages.ExceptionInfo> deployClasses(DataserviceMessages.DeployClassesRequest request)

enrichClass

public com.google.common.util.concurrent.ListenableFuture<CommonMessages.ExceptionInfo> enrichClass(DataserviceMessages.EnrichClassRequest request)

newPersistentInstance

public com.google.common.util.concurrent.ListenableFuture<DataserviceMessages.NewPersistentInstanceResponse> newPersistentInstance(DataserviceMessages.NewPersistentInstanceRequest request)

 Execution Environment
 

storeObjects

public com.google.common.util.concurrent.ListenableFuture<CommonMessages.ExceptionInfo> storeObjects(DataserviceMessages.StoreObjectsRequest request)

getCopyOfObject

public com.google.common.util.concurrent.ListenableFuture<DataserviceMessages.GetCopyOfObjectResponse> getCopyOfObject(DataserviceMessages.GetCopyOfObjectRequest request)

updateObject

public com.google.common.util.concurrent.ListenableFuture<CommonMessages.ExceptionInfo> updateObject(DataserviceMessages.UpdateObjectRequest request)

getObjects

public com.google.common.util.concurrent.ListenableFuture<DataserviceMessages.GetObjectsResponse> getObjects(DataserviceMessages.GetObjectsRequest request)

newVersion

public com.google.common.util.concurrent.ListenableFuture<DataserviceMessages.NewVersionResponse> newVersion(DataserviceMessages.NewVersionRequest request)

consolidateVersion

public com.google.common.util.concurrent.ListenableFuture<CommonMessages.ExceptionInfo> consolidateVersion(DataserviceMessages.ConsolidateVersionRequest request)

upsertObjects

public com.google.common.util.concurrent.ListenableFuture<CommonMessages.ExceptionInfo> upsertObjects(DataserviceMessages.UpsertObjectsRequest request)

newReplica

public com.google.common.util.concurrent.ListenableFuture<DataserviceMessages.NewReplicaResponse> newReplica(DataserviceMessages.NewReplicaRequest request)

moveObjects

public com.google.common.util.concurrent.ListenableFuture<DataserviceMessages.MoveObjectsResponse> moveObjects(DataserviceMessages.MoveObjectsRequest request)

removeObjects

public com.google.common.util.concurrent.ListenableFuture<DataserviceMessages.RemoveObjectsResponse> removeObjects(DataserviceMessages.RemoveObjectsRequest request)

migrateObjectsToBackends

public com.google.common.util.concurrent.ListenableFuture<DataserviceMessages.MigrateObjectsResponse> migrateObjectsToBackends(DataserviceMessages.MigrateObjectsRequest request)

getClassIDFromObjectInMemory

public com.google.common.util.concurrent.ListenableFuture<DataserviceMessages.GetClassIDFromObjectInMemoryResponse> getClassIDFromObjectInMemory(DataserviceMessages.GetClassIDFromObjectInMemoryRequest request)

executeImplementation

public com.google.common.util.concurrent.ListenableFuture<DataserviceMessages.ExecuteImplementationResponse> executeImplementation(DataserviceMessages.ExecuteImplementationRequest request)

makePersistent

public com.google.common.util.concurrent.ListenableFuture<CommonMessages.ExceptionInfo> makePersistent(DataserviceMessages.MakePersistentRequest request)

federate

public com.google.common.util.concurrent.ListenableFuture<CommonMessages.ExceptionInfo> federate(DataserviceMessages.FederateRequest request)

unfederate

public com.google.common.util.concurrent.ListenableFuture<CommonMessages.ExceptionInfo> unfederate(DataserviceMessages.UnfederateRequest request)

notifyFederation

public com.google.common.util.concurrent.ListenableFuture<CommonMessages.ExceptionInfo> notifyFederation(DataserviceMessages.NotifyFederationRequest request)

notifyUnfederation

public com.google.common.util.concurrent.ListenableFuture<CommonMessages.ExceptionInfo> notifyUnfederation(DataserviceMessages.NotifyUnfederationRequest request)

exists

public com.google.common.util.concurrent.ListenableFuture<DataserviceMessages.ExistsResponse> exists(DataserviceMessages.ExistsRequest request)

synchronize

public com.google.common.util.concurrent.ListenableFuture<CommonMessages.ExceptionInfo> synchronize(DataserviceMessages.SynchronizeRequest request)

storeToDB

public com.google.common.util.concurrent.ListenableFuture<CommonMessages.ExceptionInfo> storeToDB(DataserviceMessages.StoreToDBRequest request)

 Storage Location
 

getFromDB

public com.google.common.util.concurrent.ListenableFuture<DataserviceMessages.GetFromDBResponse> getFromDB(DataserviceMessages.GetFromDBRequest request)

updateToDB

public com.google.common.util.concurrent.ListenableFuture<CommonMessages.ExceptionInfo> updateToDB(DataserviceMessages.UpdateToDBRequest request)

deleteToDB

public com.google.common.util.concurrent.ListenableFuture<CommonMessages.ExceptionInfo> deleteToDB(DataserviceMessages.DeleteToDBRequest request)

existsInDB

public com.google.common.util.concurrent.ListenableFuture<DataserviceMessages.ExistsInDBResponse> existsInDB(DataserviceMessages.ExistsInDBRequest request)

cleanExecutionClassDirectory

public com.google.common.util.concurrent.ListenableFuture<CommonMessages.ExceptionInfo> cleanExecutionClassDirectory(CommonMessages.EmptyMessage request)

 Others
 

closeDbHandler

public com.google.common.util.concurrent.ListenableFuture<CommonMessages.ExceptionInfo> closeDbHandler(CommonMessages.EmptyMessage request)

shutDown

public com.google.common.util.concurrent.ListenableFuture<CommonMessages.ExceptionInfo> shutDown(CommonMessages.EmptyMessage request)

disconnectFromOthers

public com.google.common.util.concurrent.ListenableFuture<CommonMessages.ExceptionInfo> disconnectFromOthers(CommonMessages.EmptyMessage request)

registerPendingObjects

public com.google.common.util.concurrent.ListenableFuture<CommonMessages.ExceptionInfo> registerPendingObjects(CommonMessages.EmptyMessage request)

cleanCaches

public com.google.common.util.concurrent.ListenableFuture<CommonMessages.ExceptionInfo> cleanCaches(CommonMessages.EmptyMessage request)

 Paraver
 

activateTracing

public com.google.common.util.concurrent.ListenableFuture<CommonMessages.ExceptionInfo> activateTracing(DataserviceMessages.ActivateTracingRequest request)

deactivateTracing

public com.google.common.util.concurrent.ListenableFuture<CommonMessages.ExceptionInfo> deactivateTracing(CommonMessages.EmptyMessage request)

getTraces

public com.google.common.util.concurrent.ListenableFuture<CommonMessages.GetTracesResponse> getTraces(CommonMessages.EmptyMessage request)

deleteAlias

public com.google.common.util.concurrent.ListenableFuture<CommonMessages.ExceptionInfo> deleteAlias(DataserviceMessages.DeleteAliasRequest request)

 Garbage collection
 

detachObjectFromSession

public com.google.common.util.concurrent.ListenableFuture<CommonMessages.ExceptionInfo> detachObjectFromSession(DataserviceMessages.DetachObjectFromSessionRequest request)

closeSessionInDS

public com.google.common.util.concurrent.ListenableFuture<CommonMessages.ExceptionInfo> closeSessionInDS(DataserviceMessages.CloseSessionInDSRequest request)

updateRefs

public com.google.common.util.concurrent.ListenableFuture<CommonMessages.ExceptionInfo> updateRefs(DataserviceMessages.UpdateRefsRequest request)

getRetainedReferences

public com.google.common.util.concurrent.ListenableFuture<DataserviceMessages.GetRetainedReferencesResponse> getRetainedReferences(CommonMessages.EmptyMessage request)

getNumObjects

public com.google.common.util.concurrent.ListenableFuture<CommonMessages.GetNumObjectsResponse> getNumObjects(CommonMessages.EmptyMessage request)

getNumObjectsInEE

public com.google.common.util.concurrent.ListenableFuture<CommonMessages.GetNumObjectsResponse> getNumObjectsInEE(CommonMessages.EmptyMessage request)