public class JavaFilesystemArtifactStagingService extends AbstractArtifactStagingService
ArtifactStagingServiceGrpc.ArtifactStagingServiceImplBase
that loads artifacts into a
Java FileSystem
.Modifier and Type | Field and Description |
---|---|
static java.lang.String |
ARTIFACTS |
static java.lang.String |
MANIFEST |
NO_ARTIFACTS_STAGED_TOKEN
Constructor and Description |
---|
JavaFilesystemArtifactStagingService(java.nio.file.FileSystem fileSystem,
java.lang.String artifactRootDir) |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getArtifactUri(java.lang.String stagingSessionToken,
java.lang.String encodedFileName) |
java.lang.String |
getRetrievalToken(java.lang.String stagingSessionToken) |
java.nio.channels.WritableByteChannel |
openManifest(java.lang.String stagingSessionToken) |
java.nio.channels.WritableByteChannel |
openUri(java.lang.String uri) |
void |
removeArtifacts(java.lang.String stagingSessionToken) |
void |
removeUri(java.lang.String uri) |
close, commitManifest, putArtifact
bindService
public static final java.lang.String MANIFEST
public static final java.lang.String ARTIFACTS
public JavaFilesystemArtifactStagingService(java.nio.file.FileSystem fileSystem, java.lang.String artifactRootDir)
public java.lang.String getArtifactUri(java.lang.String stagingSessionToken, java.lang.String encodedFileName) throws java.lang.Exception
getArtifactUri
in class AbstractArtifactStagingService
java.lang.Exception
public java.nio.channels.WritableByteChannel openUri(java.lang.String uri) throws java.io.IOException
openUri
in class AbstractArtifactStagingService
java.io.IOException
public void removeUri(java.lang.String uri) throws java.io.IOException
removeUri
in class AbstractArtifactStagingService
java.io.IOException
public java.nio.channels.WritableByteChannel openManifest(java.lang.String stagingSessionToken) throws java.lang.Exception
openManifest
in class AbstractArtifactStagingService
java.lang.Exception
public void removeArtifacts(java.lang.String stagingSessionToken) throws java.lang.Exception
removeArtifacts
in class AbstractArtifactStagingService
java.lang.Exception
public java.lang.String getRetrievalToken(java.lang.String stagingSessionToken) throws java.lang.Exception
getRetrievalToken
in class AbstractArtifactStagingService
java.lang.Exception