Package org.opencastproject.assetmanager.aws

Class AwsAbstractArchive

java.lang.Object

org.opencastproject.assetmanager.aws.AwsAbstractArchive

All Implemented Interfaces:

org.opencastproject.assetmanager.api.storage.AssetStore, org.opencastproject.storage.StorageUsage

Direct Known Subclasses:

AwsS3AssetStore

public abstract class AwsAbstractArchive
extends Object
implements org.opencastproject.assetmanager.api.storage.AssetStore

Field Summary

Fields

Modifier and Type	Field	Description
protected AwsAssetDatabase	database
protected String	regionName	The AWS region
protected String	storeType	The store type e.g. aws (long-term), or other implementations
protected org.opencastproject.workspace.api.Workspace	workspace

Fields inherited from interface org.opencastproject.assetmanager.api.storage.AssetStore

STORE_TYPE_PROPERTY

Constructor Summary

Constructors

Constructor	Description
AwsAbstractArchive()

Method Summary

Modifier and Type	Method	Description
protected String	buildFilename(org.opencastproject.assetmanager.api.storage.StoragePath path, String ext)	Builds the aws object name.
String	buildObjectName(File origin, org.opencastproject.assetmanager.api.storage.StoragePath storagePath)
boolean	contains(org.opencastproject.assetmanager.api.storage.StoragePath path)
boolean	copy(org.opencastproject.assetmanager.api.storage.StoragePath from, org.opencastproject.assetmanager.api.storage.StoragePath to)
boolean	delete(org.opencastproject.assetmanager.api.storage.DeletionSelector sel)
protected abstract void	deleteObject(AwsAssetMapping map)
Optional<InputStream>	get(org.opencastproject.assetmanager.api.storage.StoragePath path)
protected String	getAWSConfigKey(org.osgi.service.component.ComponentContext cc, String key)
protected File	getFileFromWorkspace(org.opencastproject.assetmanager.api.storage.Source source)
protected abstract InputStream	getObject(AwsAssetMapping map)
String	getRegion()
String	getStoreType()
Optional<Long>	getTotalSpace()
Optional<Long>	getUsableSpace()
Optional<Long>	getUsedSpace()
void	put(org.opencastproject.assetmanager.api.storage.StoragePath storagePath, org.opencastproject.assetmanager.api.storage.Source source)
void	setDatabase(AwsAssetDatabase db)	OSGi Di
void	setWorkspace(org.opencastproject.workspace.api.Workspace workspace)	OSGi Di
protected abstract AwsUploadOperationResult	uploadObject(String orgId, File origin, String objectName, Optional<org.opencastproject.util.MimeType> mimeType)

Methods inherited from class java.lang.Object

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

Field Details

workspace

protected org.opencastproject.workspace.api.Workspace workspace

database

protected AwsAssetDatabase database

storeType

protected String storeType

The store type e.g. aws (long-term), or other implementations

regionName

protected String regionName

The AWS region

Constructor Details

AwsAbstractArchive

public AwsAbstractArchive()

Method Details

getAWSConfigKey

protected String getAWSConfigKey(org.osgi.service.component.ComponentContext cc,
 String key)

getUsedSpace

public Optional<Long> getUsedSpace()

Specified by:

getUsedSpace in interface org.opencastproject.storage.StorageUsage

getUsableSpace

public Optional<Long> getUsableSpace()

Specified by:

getUsableSpace in interface org.opencastproject.storage.StorageUsage

getTotalSpace

public Optional<Long> getTotalSpace()

Specified by:

getTotalSpace in interface org.opencastproject.storage.StorageUsage

getStoreType

public String getStoreType()

Specified by:

getStoreType in interface org.opencastproject.assetmanager.api.storage.AssetStore

getRegion

public String getRegion()

setWorkspace

public void setWorkspace(org.opencastproject.workspace.api.Workspace workspace)

OSGi Di

setDatabase

public void setDatabase(AwsAssetDatabase db)

OSGi Di

copy

public boolean copy(org.opencastproject.assetmanager.api.storage.StoragePath from,
 org.opencastproject.assetmanager.api.storage.StoragePath to)
             throws org.opencastproject.assetmanager.api.storage.AssetStoreException

Specified by:

copy in interface org.opencastproject.assetmanager.api.storage.AssetStore

Throws:

org.opencastproject.assetmanager.api.storage.AssetStoreException

See Also:

• AssetStore.copy(StoragePath, StoragePath)

contains

public boolean contains(org.opencastproject.assetmanager.api.storage.StoragePath path)
                 throws org.opencastproject.assetmanager.api.storage.AssetStoreException

Specified by:

contains in interface org.opencastproject.assetmanager.api.storage.AssetStore

Throws:

org.opencastproject.assetmanager.api.storage.AssetStoreException

getFileFromWorkspace

protected File getFileFromWorkspace(org.opencastproject.assetmanager.api.storage.Source source)

buildObjectName

public String buildObjectName(File origin,
 org.opencastproject.assetmanager.api.storage.StoragePath storagePath)

buildFilename

protected String buildFilename(org.opencastproject.assetmanager.api.storage.StoragePath path,
 String ext)

Builds the aws object name.

put

public void put(org.opencastproject.assetmanager.api.storage.StoragePath storagePath,
 org.opencastproject.assetmanager.api.storage.Source source)
         throws org.opencastproject.assetmanager.api.storage.AssetStoreException

Specified by:

put in interface org.opencastproject.assetmanager.api.storage.AssetStore

Throws:

org.opencastproject.assetmanager.api.storage.AssetStoreException

See Also:

• AssetStore.put(StoragePath, Source)

uploadObject

protected abstract AwsUploadOperationResult uploadObject(String orgId,
 File origin,
 String objectName,
 Optional<org.opencastproject.util.MimeType> mimeType)
                                                  throws org.opencastproject.assetmanager.api.storage.AssetStoreException

Throws:

org.opencastproject.assetmanager.api.storage.AssetStoreException

get

public Optional<InputStream> get(org.opencastproject.assetmanager.api.storage.StoragePath path)
                          throws org.opencastproject.assetmanager.api.storage.AssetStoreException

Specified by:

get in interface org.opencastproject.assetmanager.api.storage.AssetStore

Throws:

org.opencastproject.assetmanager.api.storage.AssetStoreException

See Also:

• AssetStore.get(StoragePath)

getObject

protected abstract InputStream getObject(AwsAssetMapping map)
                                  throws org.opencastproject.assetmanager.api.storage.AssetStoreException

Throws:

org.opencastproject.assetmanager.api.storage.AssetStoreException

delete

public boolean delete(org.opencastproject.assetmanager.api.storage.DeletionSelector sel)
               throws org.opencastproject.assetmanager.api.storage.AssetStoreException

Specified by:

delete in interface org.opencastproject.assetmanager.api.storage.AssetStore

Throws:

org.opencastproject.assetmanager.api.storage.AssetStoreException

See Also:

• AssetStore.delete(DeletionSelector)

deleteObject

protected abstract void deleteObject(AwsAssetMapping map)
                              throws org.opencastproject.assetmanager.api.storage.AssetStoreException

Throws:

org.opencastproject.assetmanager.api.storage.AssetStoreException