org.duracloud.s3task.streaming

Class BaseStreamingTaskRunner

java.lang.Object

org.duracloud.s3task.streaming.BaseStreamingTaskRunner

All Implemented Interfaces:

TaskRunner

Direct Known Subclasses:

AddStreamingItemTaskRunner, DeleteStreamingTaskRunner, DisableStreamingTaskRunner, EnableStreamingTaskRunner

public abstract class BaseStreamingTaskRunner
extends Object
implements TaskRunner

Field Summary

Fields

Modifier and Type	Field and Description
protected org.jets3t.service.CloudFrontService	cfService
protected static int	maxRetries
protected com.amazonaws.services.s3.AmazonS3Client	s3Client
protected S3StorageProvider	s3Provider

Constructor Summary

Constructors

Constructor and Description
BaseStreamingTaskRunner()

Method Summary

Methods

Modifier and Type	Method and Description
protected List<org.jets3t.service.model.cloudfront.StreamingDistribution>	getAllExistingDistributions(String bucketName)
protected String	getDistributionOriginAccessId(String distributionId)
protected org.jets3t.service.model.cloudfront.StreamingDistribution	getExistingDistribution(String bucketName)
abstract String	getName()
protected Iterator<String>	getSpaceContents(String spaceId)
protected String	getSpaceId(String taskParameters)
abstract String	performTask(String taskParameters)
protected void	setACL(String bucketName, String contentId, com.amazonaws.services.s3.model.CanonicalGrantee s3Grantee)
protected void	wait(int index)

Methods inherited from class java.lang.Object

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

Field Detail

maxRetries

protected static final int maxRetries

See Also:

Constant Field Values

s3Provider

protected S3StorageProvider s3Provider

s3Client

protected com.amazonaws.services.s3.AmazonS3Client s3Client

cfService

protected org.jets3t.service.CloudFrontService cfService

Constructor Detail

BaseStreamingTaskRunner

public BaseStreamingTaskRunner()

Method Detail

getName

public abstract String getName()

Specified by:

getName in interface TaskRunner

performTask

public abstract String performTask(String taskParameters)

Specified by:

performTask in interface TaskRunner

getSpaceId

protected String getSpaceId(String taskParameters)

getExistingDistribution

protected org.jets3t.service.model.cloudfront.StreamingDistribution getExistingDistribution(String bucketName)
                                                                                     throws org.jets3t.service.CloudFrontServiceException

Throws:

org.jets3t.service.CloudFrontServiceException

getAllExistingDistributions

protected List<org.jets3t.service.model.cloudfront.StreamingDistribution> getAllExistingDistributions(String bucketName)
                                                                                               throws org.jets3t.service.CloudFrontServiceException

Throws:

org.jets3t.service.CloudFrontServiceException

getSpaceContents

protected Iterator<String> getSpaceContents(String spaceId)

getDistributionOriginAccessId

protected String getDistributionOriginAccessId(String distributionId)
                                        throws org.jets3t.service.CloudFrontServiceException

Throws:

org.jets3t.service.CloudFrontServiceException

setACL

protected void setACL(String bucketName,
          String contentId,
          com.amazonaws.services.s3.model.CanonicalGrantee s3Grantee)
               throws DuraCloudCheckedException

Throws:

DuraCloudCheckedException

wait

protected void wait(int index)