Uses of Class
io.clonecloudstore.accessor.model.AccessorObject
Packages that use AccessorObject
Package
Description
-
Uses of AccessorObject in io.clonecloudstore.accessor.apache.client
Methods in io.clonecloudstore.accessor.apache.client that return AccessorObjectModifier and TypeMethodDescriptionAccessorClient.createObject(AccessorObject accessorObject, InputStream body) AccessorClient.createObject(AccessorObject accessorObject, InputStream body, boolean useCompression) AccessorClient.getObjectInfo(String bucketName, String objectName) Methods in io.clonecloudstore.accessor.apache.client that return types with arguments of type AccessorObjectModifier and TypeMethodDescriptionNote: Compression is only between client and server, result InputStream is uncompressedAccessorClient.listObjects(String bucketName, AccessorFilter filter) Returns an Iterator containing AccessorObjectsMethods in io.clonecloudstore.accessor.apache.client with parameters of type AccessorObjectModifier and TypeMethodDescriptionAccessorClient.createObject(AccessorObject accessorObject, InputStream body) AccessorClient.createObject(AccessorObject accessorObject, InputStream body, boolean useCompression) -
Uses of AccessorObject in io.clonecloudstore.accessor.client
Methods in io.clonecloudstore.accessor.client that return AccessorObjectModifier and TypeMethodDescriptionAccessorObjectApiClient.createObject(AccessorObject accessorObject, String clientId, InputStream body) AccessorObjectApiClient.createObject(AccessorObject accessorObject, String clientId, InputStream body, boolean compressed) protected AccessorObjectAccessorObjectApiClient.getApiBusinessOutFromResponseForCreate(jakarta.ws.rs.core.Response response) AccessorObjectApiClient.getObjectInfo(String bucketName, String objectName, String clientId) Methods in io.clonecloudstore.accessor.client that return types with arguments of type AccessorObjectModifier and TypeMethodDescriptionAccessorObjectApiClient.getObject(String bucketName, String objectName, String clientId, boolean compressed) Note: Compression is only between client and server, result InputStream is uncompressedAccessorObjectApiClient.listObjects(String bucketName, String clientId, AccessorFilter filter) Returns an Iterator containing AccessorObjectsMethods in io.clonecloudstore.accessor.client with parameters of type AccessorObjectModifier and TypeMethodDescriptionAccessorObjectApiClient.createObject(AccessorObject accessorObject, String clientId, InputStream body) AccessorObjectApiClient.createObject(AccessorObject accessorObject, String clientId, InputStream body, boolean compressed) AccessorObjectApiClient.getHeadersFor(AccessorObject businessIn, int context) -
Uses of AccessorObject in io.clonecloudstore.accessor.client.api
Methods in io.clonecloudstore.accessor.client.api that return AccessorObjectModifier and TypeMethodDescriptionprotected AccessorObjectResponseObjectClientFilter.getOutFromHeader(org.jboss.resteasy.reactive.client.spi.ResteasyReactiveClientRequestContext requestContext, jakarta.ws.rs.client.ClientResponseContext responseContext, jakarta.ws.rs.core.MultivaluedMap<String, String> headers) Methods in io.clonecloudstore.accessor.client.api that return types with arguments of type AccessorObjectModifier and TypeMethodDescriptionio.smallrye.mutiny.Uni<AccessorObject> AccessorObjectApi.getObjectInfo(String bucketName, String objectName, String clientId, String opId) -
Uses of AccessorObject in io.clonecloudstore.accessor.client.internal
Methods in io.clonecloudstore.accessor.client.internal that return AccessorObjectModifier and TypeMethodDescriptionprotected AccessorObjectAccessorObjectInternalApiClient.getApiBusinessOutFromResponseForCreate(jakarta.ws.rs.core.Response response) AccessorObjectInternalApiClient.getObjectInfo(String bucketName, String objectName, String clientId) Methods in io.clonecloudstore.accessor.client.internal that return types with arguments of type AccessorObjectModifier and TypeMethodDescriptionAccessorObjectInternalApiClient.getObject(String bucketName, String objectName, String clientId, boolean decompress) Returns the InputStream and the AccessorObjectAccessorObjectInternalApiClient.listObjects(String bucketName, String clientId, AccessorFilter filter) Returns an Iterator containing AccessorObjectsMethods in io.clonecloudstore.accessor.client.internal with parameters of type AccessorObjectModifier and TypeMethodDescriptionAccessorObjectInternalApiClient.getHeadersFor(AccessorObject businessIn, int context) -
Uses of AccessorObject in io.clonecloudstore.accessor.client.internal.api
Methods in io.clonecloudstore.accessor.client.internal.api that return AccessorObjectModifier and TypeMethodDescriptionprotected AccessorObjectResponseObjectClientFilter.getOutFromHeader(org.jboss.resteasy.reactive.client.spi.ResteasyReactiveClientRequestContext requestContext, jakarta.ws.rs.client.ClientResponseContext responseContext, jakarta.ws.rs.core.MultivaluedMap<String, String> headers) Methods in io.clonecloudstore.accessor.client.internal.api that return types with arguments of type AccessorObjectModifier and TypeMethodDescriptionio.smallrye.mutiny.Uni<AccessorObject> AccessorObjectInternalApi.getObjectInfo(String bucketName, String objectName, String clientId, String opId) -
Uses of AccessorObject in io.clonecloudstore.accessor.client.model
Methods in io.clonecloudstore.accessor.client.model with parameters of type AccessorObjectModifier and TypeMethodDescriptionstatic voidAccessorHeaderDtoConverter.objectFromMap(AccessorObject accessorObject, io.vertx.core.MultiMap headers) Headers to AccessorObjectstatic voidAccessorHeaderDtoConverter.objectFromMap(AccessorObject accessorObject, jakarta.ws.rs.core.MultivaluedMap<String, String> headers) Headers to AccessorObjectstatic voidAccessorHeaderDtoConverter.objectToMap(AccessorObject accessorObject, Map<String, String> map) AccessorObject to Headers -
Uses of AccessorObject in io.clonecloudstore.accessor.model
Methods in io.clonecloudstore.accessor.model that return AccessorObjectModifier and TypeMethodDescriptionAccessorObject.addMetadata(String key, String value) AccessorObject.cloneInstance()AccessorObject.setCreation(Instant creation) AccessorObject.setExpires(Instant expires) AccessorObject.setMetadata(Map<String, String> metadata) AccessorObject.setSize(long size) AccessorObject.setStatus(AccessorStatus status) -
Uses of AccessorObject in io.clonecloudstore.accessor.server.application
Methods in io.clonecloudstore.accessor.server.application that return AccessorObjectModifier and TypeMethodDescriptionAccessorObjectService.createObject(AccessorObject accessorObject, String hash, long len, String clientId) Before really creating Object, creates it in DB if possibleAccessorObjectService.createObjectFinalize(AccessorObject accessorObject, String hash, long len, String clientId, boolean external) Once Object really created in Driver Storage, finalize the Object in DB and Replicator if neededAccessorObjectService.getObjectInfo(String bucketName, String objectName, String clientId) Get DB Object DTOMethods in io.clonecloudstore.accessor.server.application that return types with arguments of type AccessorObjectModifier and TypeMethodDescriptionAccessorObjectService.checkPullable(String bucketName, String objectName, boolean external, String clientId, String opId) Check from DB if Object is pullableAccessorObjectService.getRemotePullInputStream(String bucketName, String objectName, String clientId, String targetId, String opId) When remote read is allowed, will try to read InputStream and DTO from remoteLocalReplicatorService.remoteReadObject(String bucketName, String objectName, String clientId, String targetId, String opId) Through API Client, Get this Object and Content from remoteMethods in io.clonecloudstore.accessor.server.application with parameters of type AccessorObjectModifier and TypeMethodDescriptionprotected booleanObjectStreamHandler.checkPullAble(AccessorObject object, io.vertx.core.MultiMap headers) AccessorObjectService.createObject(AccessorObject accessorObject, String hash, long len, String clientId) Before really creating Object, creates it in DB if possibleAccessorObjectService.createObjectFinalize(AccessorObject accessorObject, String hash, long len, String clientId, boolean external) Once Object really created in Driver Storage, finalize the Object in DB and Replicator if neededObjectStreamHandler.getHeaderError(AccessorObject object, int status) protected InputStreamObjectStreamHandler.getPullInputStream(AccessorObject object) -
Uses of AccessorObject in io.clonecloudstore.accessor.server.application.buffer
Methods in io.clonecloudstore.accessor.server.application.buffer that return AccessorObjectModifier and TypeMethodDescriptionprotected AccessorObjectCcsBufferAccessorService.getAccessorObjectFromDb(String bucket, String object) Methods in io.clonecloudstore.accessor.server.application.buffer with parameters of type AccessorObjectModifier and TypeMethodDescriptionprotected voidCcsBufferAccessorService.updateStatusAccessorObject(AccessorObject object, AccessorStatus status) -
Uses of AccessorObject in io.clonecloudstore.accessor.server.commons
Classes in io.clonecloudstore.accessor.server.commons with type parameters of type AccessorObjectModifier and TypeClassDescriptionclassAbstractAccessorPrivateObjectResource<H extends StreamHandlerAbstract<AccessorObject,AccessorObject>> classAbstractAccessorPrivateObjectResource<H extends StreamHandlerAbstract<AccessorObject,AccessorObject>> classAbstractAccessorPublicObjectResource<H extends StreamHandlerAbstract<AccessorObject,AccessorObject>> classAbstractAccessorPublicObjectResource<H extends StreamHandlerAbstract<AccessorObject,AccessorObject>> classclassclassclassFields in io.clonecloudstore.accessor.server.commons with type parameters of type AccessorObjectModifier and TypeFieldDescriptionprotected AtomicReference<AccessorObject> AbstractObjectStreamHandler.checkedMethods in io.clonecloudstore.accessor.server.commons that return AccessorObjectModifier and TypeMethodDescriptionAccessorObjectServiceInterface.createObject(AccessorObject accessorObject, String hash, long len, String clientId) Before really creating Object, creates it in DB if possibleAccessorObjectServiceInterface.createObjectFinalize(AccessorObject accessorObject, String hash, long len, String clientId, boolean external) Once Object really created in Driver Storage, finalize the Object in DB and Replicator if neededprotected AccessorObjectAbstractObjectStreamHandler.getAnswerPushInputStream(AccessorObject object, String finalHash, long size) static AccessorObjectAbstractPublicObjectHelper.getFromStorageObject(StorageObject storageObject) Transform StorageObject to AccessorObject without IdAccessorObjectServiceInterface.getObjectInfo(String bucketName, String objectName, String clientId) Get DB Object DTOMethods in io.clonecloudstore.accessor.server.commons that return types with arguments of type AccessorObjectModifier and TypeMethodDescriptionio.smallrye.mutiny.Uni<AccessorObject> AbstractAccessorPrivateObjectResource.getObjectInfo(String bucketName, String objectName, String clientId, String opId) io.smallrye.mutiny.Uni<AccessorObject> AbstractAccessorPublicObjectResource.getObjectInfo(String bucketName, String objectName, String clientId, String opId) io.smallrye.mutiny.Uni<AccessorObject> AbstractPrivateObjectHelper.getObjectInfo(String bucketName, String objectName, String clientId, String opId) io.smallrye.mutiny.Uni<AccessorObject> AbstractPublicObjectHelper.getObjectInfo(String bucketName, String objectName, String clientId, String opId) Methods in io.clonecloudstore.accessor.server.commons with parameters of type AccessorObjectModifier and TypeMethodDescriptionprotected voidAbstractObjectStreamHandler.checkPushAble(AccessorObject object, MultipleActionsInputStream inputStream) AccessorObjectServiceInterface.createObject(AccessorObject accessorObject, String hash, long len, String clientId) Before really creating Object, creates it in DB if possibleAccessorObjectServiceInterface.createObjectFinalize(AccessorObject accessorObject, String hash, long len, String clientId, boolean external) Once Object really created in Driver Storage, finalize the Object in DB and Replicator if neededprotected AccessorObjectAbstractObjectStreamHandler.getAnswerPushInputStream(AccessorObject object, String finalHash, long size) AbstractObjectStreamHandler.getHeaderPullInputStream(AccessorObject objectIn) AbstractObjectStreamHandler.getHeaderPushInputStream(AccessorObject objectIn, String finalHash, long size, AccessorObject objectOut) protected io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response> AbstractPrivateObjectHelper.readObjectList(io.vertx.core.http.HttpServerRequest request, io.quarkus.resteasy.reactive.server.Closer closer, AccessorObject businessIn, boolean alreadyCompressed) Listing of Objectsprotected io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response> AbstractPublicObjectHelper.readObjectList(io.vertx.core.http.HttpServerRequest request, io.quarkus.resteasy.reactive.server.Closer closer, AccessorObject businessIn, boolean alreadyCompressed) Listing of Objects -
Uses of AccessorObject in io.clonecloudstore.accessor.server.commons.buffer
Methods in io.clonecloudstore.accessor.server.commons.buffer that return AccessorObjectModifier and TypeMethodDescriptionprotected abstract AccessorObjectCcsBufferService.getAccessorObjectFromDb(String bucket, String object) Methods in io.clonecloudstore.accessor.server.commons.buffer with parameters of type AccessorObjectModifier and TypeMethodDescriptionprotected abstract voidCcsBufferService.updateStatusAccessorObject(AccessorObject object, AccessorStatus status) Update into Database the object with the given status -
Uses of AccessorObject in io.clonecloudstore.accessor.server.database.model
Methods in io.clonecloudstore.accessor.server.database.model that return AccessorObjectMethods in io.clonecloudstore.accessor.server.database.model with parameters of type AccessorObjectModifier and TypeMethodDescriptionDaoAccessorObject.fromDto(AccessorObject dto) default voidDaoAccessorObjectRepository.updateFromDto(DaoAccessorObject daoAccessorObject, AccessorObject accessorObject) Update if needed Object from DTObooleanDaoAccessorObject.updateFromDtoExceptIdSite(AccessorObject dto) Ignore Id and Site -
Uses of AccessorObject in io.clonecloudstore.accessor.server.database.mongodb
Methods in io.clonecloudstore.accessor.server.database.mongodb that return AccessorObjectMethods in io.clonecloudstore.accessor.server.database.mongodb with parameters of type AccessorObjectConstructors in io.clonecloudstore.accessor.server.database.mongodb with parameters of type AccessorObject -
Uses of AccessorObject in io.clonecloudstore.accessor.server.resource
Methods in io.clonecloudstore.accessor.server.resource that return types with arguments of type AccessorObjectModifier and TypeMethodDescriptionio.smallrye.mutiny.Uni<AccessorObject> AccessorPublicObjectResource.getObjectInfo(String bucketName, String objectName, String clientId, String opId) -
Uses of AccessorObject in io.clonecloudstore.accessor.server.resource.internal
Methods in io.clonecloudstore.accessor.server.resource.internal that return types with arguments of type AccessorObjectModifier and TypeMethodDescriptionio.smallrye.mutiny.Uni<AccessorObject> AccessorObjectInternalResource.getObjectInfo(String bucketName, String objectName, String clientId, String opId) -
Uses of AccessorObject in io.clonecloudstore.accessor.server.simple.application
Methods in io.clonecloudstore.accessor.server.simple.application that return AccessorObjectModifier and TypeMethodDescriptionAccessorObjectService.createObject(AccessorObject accessorObject, String hash, long len, String clientId) Before really creating Object, creates it in DB if possibleAccessorObjectService.createObjectFinalize(AccessorObject accessorObject, String hash, long len, String clientId, boolean external) Once Object really created in Driver Storage, finalize the Object in DB and Replicator if neededAccessorObjectService.getObjectInfo(String bucketName, String objectName, String clientId) Get DB Object DTOMethods in io.clonecloudstore.accessor.server.simple.application with parameters of type AccessorObjectModifier and TypeMethodDescriptionprotected booleanObjectStreamHandler.checkPullAble(AccessorObject object, io.vertx.core.MultiMap headers) AccessorObjectService.createObject(AccessorObject accessorObject, String hash, long len, String clientId) Before really creating Object, creates it in DB if possibleAccessorObjectService.createObjectFinalize(AccessorObject accessorObject, String hash, long len, String clientId, boolean external) Once Object really created in Driver Storage, finalize the Object in DB and Replicator if neededObjectStreamHandler.getHeaderError(AccessorObject object, int status) protected InputStreamObjectStreamHandler.getPullInputStream(AccessorObject object) -
Uses of AccessorObject in io.clonecloudstore.accessor.server.simple.application.buffer
Methods in io.clonecloudstore.accessor.server.simple.application.buffer that return AccessorObjectModifier and TypeMethodDescriptionprotected AccessorObjectCcsBufferAccessorGatewayService.getAccessorObjectFromDb(String bucket, String object) Methods in io.clonecloudstore.accessor.server.simple.application.buffer with parameters of type AccessorObjectModifier and TypeMethodDescriptionprotected voidCcsBufferAccessorGatewayService.updateStatusAccessorObject(AccessorObject object, AccessorStatus status) -
Uses of AccessorObject in io.clonecloudstore.accessor.server.simple.resource
Methods in io.clonecloudstore.accessor.server.simple.resource that return types with arguments of type AccessorObjectModifier and TypeMethodDescriptionio.smallrye.mutiny.Uni<AccessorObject> AccessorPublicObjectResource.getObjectInfo(String bucketName, String objectName, String clientId, String opId) -
Uses of AccessorObject in io.clonecloudstore.replicator.client
Methods in io.clonecloudstore.replicator.client that return AccessorObjectModifier and TypeMethodDescriptionprotected AccessorObjectLocalReplicatorApiClient.getApiBusinessOutFromResponseForCreate(jakarta.ws.rs.core.Response response) Methods in io.clonecloudstore.replicator.client that return types with arguments of type AccessorObject -
Uses of AccessorObject in io.clonecloudstore.replicator.client.api
Methods in io.clonecloudstore.replicator.client.api that return AccessorObjectModifier and TypeMethodDescriptionprotected AccessorObjectResponseObjectClientFilter.getOutFromHeader(org.jboss.resteasy.reactive.client.spi.ResteasyReactiveClientRequestContext requestContext, jakarta.ws.rs.client.ClientResponseContext responseContext, jakarta.ws.rs.core.MultivaluedMap<String, String> headers) -
Uses of AccessorObject in io.clonecloudstore.replicator.server.local.resource
Methods in io.clonecloudstore.replicator.server.local.resource that return AccessorObjectModifier and TypeMethodDescriptionprotected AccessorObjectLocalReplicatorStreamHandler.getAnswerPushInputStream(ReplicatorOrder replicatorOrder, String finalHash, long size) Methods in io.clonecloudstore.replicator.server.local.resource with parameters of type AccessorObjectModifier and TypeMethodDescriptionLocalReplicatorStreamHandler.getHeaderPushInputStream(ReplicatorOrder replicatorOrder, String finalHash, long size, AccessorObject accessorObject) -
Uses of AccessorObject in io.clonecloudstore.replicator.server.remote.client
Methods in io.clonecloudstore.replicator.server.remote.client that return AccessorObjectModifier and TypeMethodDescriptionprotected AccessorObjectRemoteReplicatorApiClient.getApiBusinessOutFromResponseForCreate(jakarta.ws.rs.core.Response response) Methods in io.clonecloudstore.replicator.server.remote.client that return types with arguments of type AccessorObjectModifier and TypeMethodDescriptionRemoteReplicatorApiClient.readRemoteObject(String bucket, String object, String clientId, String opId, long len) -
Uses of AccessorObject in io.clonecloudstore.replicator.server.remote.client.api
Methods in io.clonecloudstore.replicator.server.remote.client.api that return AccessorObjectModifier and TypeMethodDescriptionprotected AccessorObjectResponseObjectClientFilter.getOutFromHeader(org.jboss.resteasy.reactive.client.spi.ResteasyReactiveClientRequestContext requestContext, jakarta.ws.rs.client.ClientResponseContext responseContext, jakarta.ws.rs.core.MultivaluedMap<String, String> headers) -
Uses of AccessorObject in io.clonecloudstore.replicator.server.remote.resource
Methods in io.clonecloudstore.replicator.server.remote.resource that return AccessorObjectModifier and TypeMethodDescriptionprotected AccessorObjectRemoteReplicatorStreamHandler.getAnswerPushInputStream(ReplicatorOrder replicatorOrder, String finalHash, long size) Methods in io.clonecloudstore.replicator.server.remote.resource with parameters of type AccessorObjectModifier and TypeMethodDescriptionRemoteReplicatorStreamHandler.getHeaderPushInputStream(ReplicatorOrder replicatorOrder, String finalHash, long size, AccessorObject accessorObject) -
Uses of AccessorObject in io.clonecloudstore.test.accessor.common
Methods in io.clonecloudstore.test.accessor.common that return AccessorObjectModifier and TypeMethodDescriptionstatic AccessorObjectFakeCommonObjectResourceHelper.getAccessorObjectForCreate(io.vertx.core.http.HttpServerRequest request, String bucketName, String objectName, String clientId, long xObjectSize) static AccessorObjectFakeCommonObjectResourceHelper.getAccessorObjectForGetObject(String bucketName, String objectName, String clientId) protected AccessorObjectFakeStreamHandlerAbstract.getAnswerPushInputStream(AccessorObject object, String finalHash, long size) Methods in io.clonecloudstore.test.accessor.common that return types with arguments of type AccessorObjectModifier and TypeMethodDescriptionprotected io.smallrye.mutiny.Uni<AccessorObject> FakeAccessorObjectPrivateAbstract.getObjectInfo0(String bucketName, String objectName, String clientId) protected io.smallrye.mutiny.Uni<AccessorObject> FakeAccessorObjectPublicAbstract.getObjectInfo0(String bucketName, String objectName, String clientId) static io.smallrye.mutiny.Uni<AccessorObject> FakeCommonObjectResourceHelper.getObjectInfo0Helper(String bucketName, String objectName, String clientId) Methods in io.clonecloudstore.test.accessor.common with parameters of type AccessorObjectModifier and TypeMethodDescriptionprotected booleanFakeStreamHandlerAbstract.checkPullAble(AccessorObject object, io.vertx.core.MultiMap headers) protected voidFakeStreamHandlerAbstract.checkPushAble(AccessorObject object, MultipleActionsInputStream inputStream) protected booleanFakeStreamHandlerAbstract.checkRemotePullable(AccessorObject object, io.vertx.core.MultiMap headers, String clientId) Could be overridden to take into account remote checkprotected AccessorObjectFakeStreamHandlerAbstract.getAnswerPushInputStream(AccessorObject object, String finalHash, long size) FakeStreamHandlerAbstract.getHeaderError(AccessorObject object, int status) protected InputStreamFakeStreamHandlerAbstract.getPullInputStream(AccessorObject object) protected InputStreamFakeStreamHandlerAbstract.getRemotePullInputStream(AccessorObject object, String clientId) Could be overridden to use remote accessprotected booleanFakeStreamHandlerAbstract.internalCheckPullable(AccessorObject object) protected voidFakeStreamHandlerAbstract.remoteCreation(AccessorObject objectOut, String clientId) Could be overridden to take into account remote creationMethod parameters in io.clonecloudstore.test.accessor.common with type arguments of type AccessorObjectModifier and TypeMethodDescriptionprotected voidFakeAccessorObjectPrivateAbstract.getObjectInfo(io.smallrye.mutiny.subscription.UniEmitter<? super AccessorObject> em, String bucketName, String objectName, String clientId) protected voidFakeAccessorObjectPublicAbstract.getObjectInfo(io.smallrye.mutiny.subscription.UniEmitter<? super AccessorObject> em, String bucketName, String objectName, String clientId) protected voidFakeObjectPrivateAbstract.getObjectInfo(io.smallrye.mutiny.subscription.UniEmitter<? super AccessorObject> em, String bucketName, String objectName, String clientId) static voidFakeCommonObjectResourceHelper.getObjectInfoHelper(io.smallrye.mutiny.subscription.UniEmitter<? super AccessorObject> em, String bucketName, String objectName, String clientId) -
Uses of AccessorObject in io.clonecloudstore.test.accessor.server.resource
Methods in io.clonecloudstore.test.accessor.server.resource that return types with arguments of type AccessorObjectModifier and TypeMethodDescriptionio.smallrye.mutiny.Uni<AccessorObject> FakeObjectPublicResourceAbstract.getObjectInfo(String bucketName, String objectName, String clientId, String opId) -
Uses of AccessorObject in io.clonecloudstore.test.accessor.server.resource.internal
Methods in io.clonecloudstore.test.accessor.server.resource.internal that return types with arguments of type AccessorObjectModifier and TypeMethodDescriptionio.smallrye.mutiny.Uni<AccessorObject> FakeObjectPrivateResourceAbstract.getObjectInfo(String bucketName, String objectName, String clientId, String opId)