public abstract class BaseStreamingTaskRunner extends Object implements TaskRunner
Modifier and Type | Field and Description |
---|---|
protected org.jets3t.service.CloudFrontService |
cfService |
protected static int |
maxRetries |
protected com.amazonaws.services.s3.AmazonS3Client |
s3Client |
protected StorageProvider |
s3Provider |
static String |
STREAMING_HOST_PROP |
protected S3StorageProvider |
unwrappedS3Provider |
Constructor and Description |
---|
BaseStreamingTaskRunner() |
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 |
removeStreamingHostFromSpaceProps(String spaceId) |
protected void |
wait(int index) |
public static final String STREAMING_HOST_PROP
protected static final int maxRetries
protected StorageProvider s3Provider
protected S3StorageProvider unwrappedS3Provider
protected com.amazonaws.services.s3.AmazonS3Client s3Client
protected org.jets3t.service.CloudFrontService cfService
public abstract String getName()
getName
in interface TaskRunner
public abstract String performTask(String taskParameters)
performTask
in interface TaskRunner
protected org.jets3t.service.model.cloudfront.StreamingDistribution getExistingDistribution(String bucketName) throws org.jets3t.service.CloudFrontServiceException
org.jets3t.service.CloudFrontServiceException
protected List<org.jets3t.service.model.cloudfront.StreamingDistribution> getAllExistingDistributions(String bucketName) throws org.jets3t.service.CloudFrontServiceException
org.jets3t.service.CloudFrontServiceException
protected String getDistributionOriginAccessId(String distributionId) throws org.jets3t.service.CloudFrontServiceException
org.jets3t.service.CloudFrontServiceException
protected void removeStreamingHostFromSpaceProps(String spaceId)
protected void wait(int index)
Copyright © 2009–2014 DuraSpace. All rights reserved.