net.bluemind.sds.store.s3

Class S3Store

java.lang.Object

net.bluemind.sds.store.s3.S3Store

All Implemented Interfaces:

ISdsBackingStore

public class S3Store
extends java.lang.Object
implements ISdsBackingStore

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	S3PATH_PREFIX

Constructor Summary

Constructors

Constructor and Description
S3Store(S3Configuration s3Configuration, com.netflix.spectator.api.Registry registry, IdFactory idfactory)

Method Summary

Modifier and Type	Method and Description
void	close()
java.util.concurrent.CompletableFuture<SdsResponse>	delete(DeleteRequest req)
java.util.concurrent.CompletableFuture<SdsResponse>	download(GetRequest req)
java.util.concurrent.CompletableFuture<SdsResponse>	downloads(MgetRequest req)
java.util.concurrent.CompletableFuture<ExistResponse>	exists(ExistRequest req)
java.lang.String	getObjectKey(java.lang.String sha1hex)
java.util.concurrent.CompletableFuture<SdsResponse>	upload(PutRequest req)

Methods inherited from class java.lang.Object

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

Field Detail

S3PATH_PREFIX

public static final java.lang.String S3PATH_PREFIX

See Also:

Constant Field Values

Constructor Detail

S3Store

public S3Store(S3Configuration s3Configuration,
               com.netflix.spectator.api.Registry registry,
               IdFactory idfactory)

Method Detail

getObjectKey

public java.lang.String getObjectKey(java.lang.String sha1hex)

exists

public java.util.concurrent.CompletableFuture<ExistResponse> exists(ExistRequest req)

Specified by:

exists in interface ISdsBackingStore

upload

public java.util.concurrent.CompletableFuture<SdsResponse> upload(PutRequest req)

Specified by:

upload in interface ISdsBackingStore

download

public java.util.concurrent.CompletableFuture<SdsResponse> download(GetRequest req)

Specified by:

download in interface ISdsBackingStore

downloads

public java.util.concurrent.CompletableFuture<SdsResponse> downloads(MgetRequest req)

Specified by:

downloads in interface ISdsBackingStore

delete

public java.util.concurrent.CompletableFuture<SdsResponse> delete(DeleteRequest req)

Specified by:

delete in interface ISdsBackingStore

close

public void close()

Specified by:

close in interface ISdsBackingStore