aws

package
v0.0.0-...-7b56046 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 28, 2017 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BatchJobTask

type BatchJobTask struct {
	Session        *session.Session
	SubmitJobInput *batch.SubmitJobInput
	PollingTime    time.Duration
	Timeout        time.Duration
}

BatchJobTask execute AWS Batch Job.

func NewBatchJobTask

func NewBatchJobTask(session *session.Session, input *batch.SubmitJobInput) *BatchJobTask

NewBatchJobTask creates a AWS Batch Job task.

func (*BatchJobTask) Execute

func (bjt *BatchJobTask) Execute() error

Execute implement Task.Execute

type LambdaInvokeTask

type LambdaInvokeTask struct {
	Session     *session.Session
	InvokeInput *lambda.InvokeInput
}

LambdaInvokeTask invokes lambda function.

func NewLambdaInvokeTask

func NewLambdaInvokeTask(sess *session.Session, input *lambda.InvokeInput) *LambdaInvokeTask

NewLambdaInvokeTask creates a lambda invoke task.

func (*LambdaInvokeTask) Execute

func (li *LambdaInvokeTask) Execute() error

Execute implement Task.Execute.

type S3BulkDownloadTask

type S3BulkDownloadTask struct {
	Session     *session.Session
	S3SrcFolder string
	DstDir      string
	Bucket      string
}

S3BulkDownloadTask downloads files in s3 folder into local dst dir.

func NewS3BulkDownloadTask

func NewS3BulkDownloadTask(sess *session.Session, s3SrcFolder, dstDir, bucket string) *S3BulkDownloadTask

NewS3BulkDownloadTask creates a s3 bulk download task.

func (*S3BulkDownloadTask) Execute

func (down *S3BulkDownloadTask) Execute() error

Execute implement Task.Execute.

type S3BulkUploadTask

type S3BulkUploadTask struct {
	Session     *session.Session
	SrcDir      string
	S3DstFolder string
	Bucket      string
}

S3BulkUploadTask uploads local files in src dir into s3 dst folder.

func NewS3BulkUploadTask

func NewS3BulkUploadTask(sess *session.Session, srcDir, s3DstDir, bucket string) *S3BulkUploadTask

NewS3BulkUploadTask creates a s3 bulk upload task.

func (*S3BulkUploadTask) Execute

func (up *S3BulkUploadTask) Execute() error

Execute implement Task.Execute

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL