Documentation ¶
Index ¶
- func DownloadS3(s3Url *S3Url, tempDir string, progressCallback func(int64, int64, float32), ...) (string, int64, error)
- func DownloadS3Partially(s3Url *S3Url, tempDir string, partialRange string, ...) (string, int64, error)
- func GetKeysInBucket(region string, bucket string) ([]string, error)
- func GetKeysInBucketPrefix(region, bucket, prefix string) ([]string, error)
- func GetPreSignedUrl(s3Url *S3Url, minutes int64) (string, error)
- func GetS3CredentialQueryString(region, serviceName string) (string, error)
- func GetSha256(data string, secret []byte) []byte
- func SubmitJob(region, jobDefinition, jobName, jobQueue string, envs []*batch.KeyValuePair, ...) (*batch.SubmitJobOutput, error)
- func TerminateJob(region, jobId, reason string) (*batch.TerminateJobOutput, error)
- func UploadS3(bucketName string, s3Folder string, localFileName string, ...) (*s3manager.UploadOutput, error)
- type AWSCredential
- type CredentialHeaders
- type S3Url
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DownloadS3 ¶
func DownloadS3Partially ¶
func GetKeysInBucketPrefix ¶
func SubmitJob ¶
func SubmitJob(region, jobDefinition, jobName, jobQueue string, envs []*batch.KeyValuePair, arrayProperties *batch.ArrayProperties, dependOn []*batch.JobDependency) (*batch.SubmitJobOutput, error)
func TerminateJob ¶
func TerminateJob(region, jobId, reason string) (*batch.TerminateJobOutput, error)
Types ¶
type AWSCredential ¶
type AWSCredential struct { AwsAccessKeyId string `json:"aws_access_key_id"` AwsSecretAccessKey string `json:"aws_secret_access_key"` }
func GetAwsCredential ¶
func GetAwsCredential(s3Url *S3Url) (*AWSCredential, error)
type CredentialHeaders ¶
type CredentialHeaders struct { SessionToken string AccessKeyId string SecretAccessKey string Signature string DateStamp string }
func GetSignature ¶
func GetSignature(region, serviceName string) (*CredentialHeaders, error)
type S3Url ¶
type S3Url struct { Region string `json:"region"` InputBucket string `json:"input_bucket"` TempBucket string `json:"temp_bucket"` OutputBucket string `json:"output_bucket"` SystemSettingsBucket string `json:"setting_bucket"` Key string `json:"key"` MediaId string `json:"media_id"` EncodingProfileForVideo string `json:"encoding_profile_for_video"` AudioType string `json:"audio_type"` EncodingProfileForAudio string `json:"encoding_profile_for_audio"` }
func GetS3UrlFromEnv ¶
func GetS3UrlFromEnv() *S3Url
Click to show internal directories.
Click to hide internal directories.