Uses of Class
com.orientechnologies.orient.client.remote.ORemoteClientSession
Packages that use ORemoteClientSession
Package
Description
-
Uses of ORemoteClientSession in com.orientechnologies.orient.client.binary
Methods in com.orientechnologies.orient.client.binary with parameters of type ORemoteClientSessionModifier and TypeMethodDescriptionvoidOChannelBinaryAsynchClient.beginRequest(byte iCommand, ORemoteClientSession session) -
Uses of ORemoteClientSession in com.orientechnologies.orient.client.remote
Methods in com.orientechnologies.orient.client.remote that return ORemoteClientSessionMethods in com.orientechnologies.orient.client.remote with parameters of type ORemoteClientSessionModifier and TypeMethodDescriptionintORemoteClient.addCluster(ORemoteClientSession session, String iClusterName, int iRequestedId) intORemoteClient.addCluster(ORemoteClientSession session, String iClusterName, Object... iArguments) <T> TORemoteClient.baseNetworkOperation(ORemoteClientSession session, ORemoteClientOperation<T> operation, String errorMessage, int retry) ORemoteClient.beginRequest(OChannelBinaryAsynchClient network, byte iCommand, ORemoteClientSession session) Acquire a network channel from the pool.static voidORemoteClient.beginResponse(OChannelBinaryAsynchClient iNetwork, ORemoteClientSession session) voidORemoteClient.beginTransaction(ORemoteClientSession session, OTransactionOptimistic transaction) ORemoteClient.ceilingPhysicalPositions(ORemoteClientSession session, int clusterId, OPhysicalPosition physicalPosition) voidORemoteClient.close(ORemoteClientSession session) voidORemoteClient.close(ORemoteClientSession session, boolean iForce) longORemoteClient.count(ORemoteClientSession session, int iClusterId) longORemoteClient.count(ORemoteClientSession session, int[] iClusterIds) longORemoteClient.countRecords(ORemoteClientSession session) booleanORemoteClient.dropCluster(ORemoteClientSession session, int iClusterId) booleanORemoteClient.dropCluster(ORemoteClientSession session, String iClusterName) ORemoteClientOperation.execute(OChannelBinaryAsynchClient network, ORemoteClientSession session) ORemoteClient.floorPhysicalPositions(ORemoteClientSession session, int clusterId, OPhysicalPosition physicalPosition) long[]ORemoteClient.getClusterDataRange(ORemoteClientSession session, int iClusterId) ORemoteClient.getClusterName(ORemoteClientSession session, int clusterId) protected StringORemoteClient.getCurrentServerURL(ORemoteClientSession session) protected StringORemoteClient.getNextAvailableServerURL(boolean iIsConnectOperation, ORemoteClientSession session) ORemoteURLs.getNextAvailableServerURL(boolean iIsConnectOperation, ORemoteClientSession session, OContextConfiguration contextConfiguration, ORemoteClient.CONNECTION_STRATEGY strategy) ORemoteClient.getRecordMetadata(ORemoteClientSession session, ORID rid) ORemoteURLs.getServerURFromList(boolean iNextAvailable, ORemoteClientSession session, OContextConfiguration contextConfiguration) ORemoteClient.getServerURL(ORemoteClientSession session) intORemoteClient.getSessionId(ORemoteClientSession session) longORemoteClient.getSize(ORemoteClientSession session) ORemoteClient.getUserName(ORemoteClientSession session) ORemoteClient.higherPhysicalPositions(ORemoteClientSession session, int iClusterId, OPhysicalPosition iClusterPosition) voidORemoteClient.importDatabase(ORemoteClientSession session, String options, InputStream inputStream, String name, OCommandOutputListener listener) ORemoteClient.incrementalBackup(ORemoteClientSession session, String backupDirectory, OCallable<Void, Void> started) voidORemoteClient.initPush(ORemoteClientSession session, OMetadataPushListener handler) booleanORemoteClient.isClosed(ORemoteClientSession session) ORemoteClient.lockRecord(ORemoteClientSession session, OIdentifiable iRecord, OStorage.LOCKING_STRATEGY lockingStrategy, long timeout) ORemoteClient.lowerPhysicalPositions(ORemoteClientSession session, int iClusterId, OPhysicalPosition physicalPosition) <T extends OBinaryResponse>
TOrientDBRemote.networkAdminOperation(OBinaryRequest<T> request, ORemoteClientSession session, String errorMessage) <T> TOrientDBRemote.networkAdminOperation(ORemoteClientOperation<T> operation, String errorMessage, ORemoteClientSession session) <T extends OBinaryResponse>
TORemoteClient.networkOperation(ORemoteClientSession session, OBinaryRequest<T> request, String errorMessage) <T extends OBinaryResponse>
TORemoteClient.networkOperationNoRetry(ORemoteClientSession session, OBinaryRequest<T> request, String errorMessage) <T extends OBinaryResponse>
TORemoteClient.networkOperationRetryTimeout(ORemoteClientSession baseSession, OBinaryRequest<T> request, String errorMessage, int retry, int timeout) voidORemoteClient.open(ORemoteClientSession session, String iUserName, String iUserPassword, OContextConfiguration conf) protected voidORemoteClient.openRemoteDatabase(ORemoteClientSession session) voidORemoteClient.openRemoteDatabase(ORemoteClientSession session, OChannelBinaryAsynchClient network) protected voidORemoteClient.openRemoteDatabase(ORemoteClientSession session, String currentURL) voidOBinaryResponse.read(OChannelDataInput network, ORemoteClientSession session) ORemoteClient.readRecord(ORemoteClientSession session, ORecordId iRid, String iFetchPlan, boolean iIgnoreCache, boolean prefetchRecords) ORemoteClient.readRecordIfVersionIsNotLatest(ORemoteClientSession session, ORecordId rid, String fetchPlan, boolean ignoreCache, int recordVersion) voidORemoteClient.reBeginTransaction(ORemoteClientSession session, OTransactionOptimistic transaction) voidORemoteClient.reload(ORemoteClientSession session) protected StringORemoteClient.reopenRemoteDatabase(ORemoteClientSession session) voidORemoteClient.rollback(ORemoteClientSession session, OTransactionInternal iTx) voidORemoteClient.stickToSession(ORemoteClientSession session) <T extends OBinaryResponse>
TORemoteClientPushThread.subscribe(OBinaryRequest<T> request, ORemoteClientSession session) voidORemoteClient.unlockRecord(ORemoteClientSession session, OIdentifiable iRecord) voidORemoteClient.unstickToSession(ORemoteClientSession session) voidORemoteClient.unsubscribeLive(ORemoteClientSession session, int monitorId) protected StringORemoteClient.useNewServerURL(ORemoteClientSession session, String iUrl) voidOBinaryRequest.write(OChannelDataOutput network, ORemoteClientSession session) -
Uses of ORemoteClientSession in com.orientechnologies.orient.client.remote.db.document
Fields in com.orientechnologies.orient.client.remote.db.document declared as ORemoteClientSessionMethods in com.orientechnologies.orient.client.remote.db.document that return ORemoteClientSessionMethods in com.orientechnologies.orient.client.remote.db.document with parameters of type ORemoteClientSessionModifier and TypeMethodDescriptionvoidODatabaseDocumentRemote.setSessionMetadata(ORemoteClientSession sessionMetadata) -
Uses of ORemoteClientSession in com.orientechnologies.orient.client.remote.message
Methods in com.orientechnologies.orient.client.remote.message with parameters of type ORemoteClientSessionModifier and TypeMethodDescriptionvoidOAddClusterResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOBatchOperationsResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOBeginTransactionResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOCeilingPhysicalPositionsResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOCleanOutRecordResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOCloseQueryResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOCommandResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOCommit37Response.read(OChannelDataInput network, ORemoteClientSession session) voidOCommitResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOConnectResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOCountRecordsResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOCountResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOCreateDatabaseResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOCreateRecordResponse.read(OChannelDataInput network, ORemoteClientSession session) voidODeleteRecordResponse.read(OChannelDataInput network, ORemoteClientSession session) voidODistributedConnectResponse.read(OChannelDataInput network, ORemoteClientSession session) voidODistributedStatusResponse.read(OChannelDataInput network, ORemoteClientSession session) voidODropClusterResponse.read(OChannelDataInput network, ORemoteClientSession session) voidODropDatabaseResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOError37Response.read(OChannelDataInput network, ORemoteClientSession session) voidOErrorResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOExistsDatabaseResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOExperimentalResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOFetchTransaction38Response.read(OChannelDataInput network, ORemoteClientSession session) voidOFetchTransactionResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOFloorPhysicalPositionsResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOFreezeDatabaseResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOGetClusterDataRangeResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOGetGlobalConfigurationResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOGetRecordMetadataResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOGetSizeResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOHideRecordResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOHigherPhysicalPositionsResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOImportResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOIncrementalBackupResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOListDatabasesResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOListGlobalConfigurationsResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOLockRecordResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOLowerPhysicalPositionsResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOOpen37Response.read(OChannelDataInput network, ORemoteClientSession session) voidOOpenResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOQueryResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOReadRecordIfVersionIsNotLatestResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOReadRecordResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOReleaseDatabaseResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOReloadResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOReloadResponse37.read(OChannelDataInput network, ORemoteClientSession session) voidOReopenResponse.read(OChannelDataInput network, ORemoteClientSession session) voidORollbackTransactionResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOSBTCreateTreeResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOSBTFetchEntriesMajorResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOSBTFirstKeyResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOSBTGetRealBagSizeResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOSBTGetResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOServerInfoResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOServerQueryResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOSetGlobalConfigurationResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOShutdownResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOSubscribeDistributedConfigurationResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOSubscribeFunctionsResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOSubscribeIndexManagerResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOSubscribeLiveQueryResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOSubscribeMetadataResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOSubscribeResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOSubscribeSchemaResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOSubscribeSequencesResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOSubscribeStorageConfigurationResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOUnlockRecordResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOUnsubscribeResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOUnsubscribLiveQueryResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOUpdateRecordResponse.read(OChannelDataInput network, ORemoteClientSession session) voidOAddClusterRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOBatchOperationsRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOBeginTransaction38Request.write(OChannelDataOutput network, ORemoteClientSession session) voidOBeginTransactionRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOCeilingPhysicalPositionsRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOCleanOutRecordRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOCloseQueryRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOCloseRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOCommandRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOCommit37Request.write(OChannelDataOutput network, ORemoteClientSession session) voidOCommit38Request.write(OChannelDataOutput network, ORemoteClientSession session) voidOCommitRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOConnect37Request.write(OChannelDataOutput network, ORemoteClientSession session) voidOConnectRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOCountRecordsRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOCountRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOCreateDatabaseRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOCreateRecordRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidODeleteRecordRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidODistributedConnectRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidODistributedStatusRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidODropClusterRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidODropDatabaseRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOExistsDatabaseRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOExperimentalRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOFetchTransaction38Request.write(OChannelDataOutput network, ORemoteClientSession session) voidOFetchTransactionRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOFloorPhysicalPositionsRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOFreezeDatabaseRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOGetClusterDataRangeRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOGetGlobalConfigurationRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOGetRecordMetadataRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOGetSizeRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOHigherPhysicalPositionsRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOImportRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOIncrementalBackupRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOListDatabasesRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOListGlobalConfigurationsRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOLockRecordRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOLowerPhysicalPositionsRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOOpen37Request.write(OChannelDataOutput network, ORemoteClientSession session) voidOOpenRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOQueryNextPageRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOQueryRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOReadRecordIfVersionIsNotLatestRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOReadRecordRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOReleaseDatabaseRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOReloadRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOReloadRequest37.write(OChannelDataOutput network, ORemoteClientSession session) voidOReopenRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidORollbackTransactionRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOSBTCreateTreeRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOSBTFetchEntriesMajorRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOSBTFirstKeyRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOSBTGetRealBagSizeRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOSBTGetRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOServerInfoRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOServerQueryRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOSetGlobalConfigurationRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOShutdownRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOSubscribeDistributedConfigurationRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOSubscribeFunctionsRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOSubscribeIndexManagerRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOSubscribeLiveQueryRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOSubscribeMetadataRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOSubscribeRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOSubscribeSchemaRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOSubscribeSequencesRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOSubscribeStorageConfigurationRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOUnlockRecordRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOUnsubscribeLiveQueryRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOUnsubscribeRequest.write(OChannelDataOutput network, ORemoteClientSession session) voidOUpdateRecordRequest.write(OChannelDataOutput network, ORemoteClientSession session)