Package io.antmedia.storage

Class AmazonS3StorageClient

java.lang.Object

io.antmedia.storage.StorageClient

io.antmedia.storage.AmazonS3StorageClient

public class AmazonS3StorageClient
extends StorageClient

Field Summary

Fields

Modifier and Type	Field	Description
private com.amazonaws.services.s3.AmazonS3	amazonS3
protected static org.slf4j.Logger	logger
private long	multipartUploadThreshold
private com.amazonaws.services.s3.transfer.TransferManager	transferManager

Fields inherited from class io.antmedia.storage.StorageClient

BEAN_NAME, progressListener

Constructor Summary

Constructors

Constructor	Description
AmazonS3StorageClient()

Method Summary

Modifier and Type	Method	Description
boolean	checkStorageClass(String s3StorageClass)
void	convert2List(List<String> list, List<com.amazonaws.services.s3.model.S3ObjectSummary> objectSummaries)
void	delete(String key)	Delete file from storage
void	deleteFile(File file)
boolean	fileExist(String key)	Check if the key exists in the bucket
com.amazonaws.services.s3.AmazonS3	getAmazonS3()
com.amazonaws.services.s3.model.CannedAccessControlList	getCannedAcl()
long	getMultipartUploadThreshold()
List<String>	getObjects(String prefix)
com.amazonaws.services.s3.transfer.TransferManager	getTransferManager()
com.amazonaws.services.s3.AmazonS3	initAmazonS3()
void	listenUploadProgress(String key, File file, boolean deleteLocalFile, com.amazonaws.services.s3.transfer.Upload upload)
void	reset()	Re-initialize the storage client with the current parameters
void	save(File file, String type)
void	save(String key, File file, boolean deleteLocalFile)	Save file to storage and delete the local file according to the parameter
void	save(String key, File file, InputStream inputStream, boolean deleteLocalFile, boolean waitForCompletion)
void	save(String key, InputStream inputStream, boolean waitForCompletion)	Save input stream to the storage with key parameter
void	setMultipartUploadThreshold(long multipartUploadThreshold)

Methods inherited from class io.antmedia.storage.StorageClient

getAccessKey, getCacheControl, getEndpoint, getPermission, getRegion, getSecretKey, getStorageClass, getStorageName, getTransferBufferSize, isEnabled, isPathStyleAccessEnabled, save, setAccessKey, setCacheControl, setEnabled, setEndpoint, setPathStyleAccessEnabled, setPermission, setProgressListener, setRegion, setSecretKey, setStorageClass, setStorageName, setTransferBufferSize

Methods inherited from class java.lang.Object

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

Field Details

amazonS3

private com.amazonaws.services.s3.AmazonS3 amazonS3

transferManager

private com.amazonaws.services.s3.transfer.TransferManager transferManager

multipartUploadThreshold

private long multipartUploadThreshold

logger

protected static org.slf4j.Logger logger

Constructor Details

AmazonS3StorageClient

public AmazonS3StorageClient()

Method Details

getAmazonS3

public com.amazonaws.services.s3.AmazonS3 getAmazonS3()

initAmazonS3

public com.amazonaws.services.s3.AmazonS3 initAmazonS3()

getObjects

public List<String> getObjects(String prefix)

convert2List

public void convert2List(List<String> list,
 List<com.amazonaws.services.s3.model.S3ObjectSummary> objectSummaries)

delete

public void delete(String key)

Description copied from class: StorageClient

Delete file from storage

Specified by:

delete in class StorageClient

fileExist

public boolean fileExist(String key)

Description copied from class: StorageClient

Check if the key exists in the bucket

Specified by:

fileExist in class StorageClient

Returns:

save

public void save(File file,
 String type)

save

public void save(String key,
 InputStream inputStream,
 boolean waitForCompletion)

Description copied from class: StorageClient

Save input stream to the storage with key parameter

Specified by:

save in class StorageClient

save

public void save(String key,
 File file,
 boolean deleteLocalFile)

Description copied from class: StorageClient

Save file to storage and delete the local file according to the parameter

Specified by:

save in class StorageClient

save

public void save(String key,
 File file,
 InputStream inputStream,
 boolean deleteLocalFile,
 boolean waitForCompletion)

listenUploadProgress

public void listenUploadProgress(String key,
 File file,
 boolean deleteLocalFile,
 com.amazonaws.services.s3.transfer.Upload upload)

checkStorageClass

public boolean checkStorageClass(String s3StorageClass)

getTransferManager

public com.amazonaws.services.s3.transfer.TransferManager getTransferManager()

deleteFile

public void deleteFile(File file)

reset

public void reset()

Description copied from class: StorageClient

Re-initialize the storage client with the current parameters

Specified by:

reset in class StorageClient

getCannedAcl

public com.amazonaws.services.s3.model.CannedAccessControlList getCannedAcl()

getMultipartUploadThreshold

public long getMultipartUploadThreshold()

setMultipartUploadThreshold

public void setMultipartUploadThreshold(long multipartUploadThreshold)