aws

Documentation

Index

• Variables
• type Dynamo
  • func (d *Dynamo) Cleanup() error
  • func (d *Dynamo) ClearWork() error
  • func (d *Dynamo) GetWork() (io.Reader, error)
  • func (d *Dynamo) HandleFailure() error
  • func (d *Dynamo) Init() error
  • func (d *Dynamo) LoadEnv(prefix string) error
  • func (d *Dynamo) LoadFlags() error
• type S3
  • func (d *S3) Cleanup() error
  • func (d *S3) ClearWork() error
  • func (d *S3) GetWork() (io.Reader, error)
  • func (d *S3) HandleFailure() error
  • func (d *S3) Init() error
  • func (d *S3) LoadEnv(prefix string) error
  • func (d *S3) LoadFlags() error
• type S3Op
  • func (o *S3Op) GetKey() string
• type S3Operation
• type SQS
  • func (d *SQS) Cleanup() error
  • func (d *SQS) ClearWork() error
  • func (d *SQS) GetWork() (io.Reader, error)
  • func (d *SQS) HandleFailure() error
  • func (d *SQS) Init() error
  • func (d *SQS) LoadEnv(prefix string) error
  • func (d *SQS) LoadFlags() error

Variables

var (
	S3OperationRM = S3Operation("rm")
	S3OperationMV = S3Operation("mv")
)

Types

type Dynamo

type Dynamo struct {
	Client           *dynamodb.DynamoDB
	Table            string
	Region           string
	RoleARN          string
	QueryKeyJSONPath *string
	DataJSONPath     *string
	RetrieveQuery    *string
	ClearQuery       *string
	FailQuery        *string
	Key              *string
}

func (*Dynamo) Cleanup

func (d *Dynamo) Cleanup() error

func (*Dynamo) ClearWork

func (d *Dynamo) ClearWork() error

func (*Dynamo) GetWork

func (d *Dynamo) GetWork() (io.Reader, error)

func (*Dynamo) HandleFailure

func (d *Dynamo) HandleFailure() error

func (*Dynamo) Init

func (d *Dynamo) Init() error

func (*Dynamo) LoadEnv

func (d *Dynamo) LoadEnv(prefix string) error

func (*Dynamo) LoadFlags

func (d *Dynamo) LoadFlags() error

type S3

type S3 struct {
	Client    *s3.S3
	Bucket    string
	Key       string
	KeyRegex  string
	KeyPrefix string
	Region    string
	RoleARN   string
	ClearOp   *S3Op
	FailOp    *S3Op
}

func (*S3) Cleanup

func (d *S3) Cleanup() error

func (*S3) ClearWork

func (d *S3) ClearWork() error

func (*S3) GetWork

func (d *S3) GetWork() (io.Reader, error)

func (*S3) HandleFailure

func (d *S3) HandleFailure() error

func (*S3) Init

func (d *S3) Init() error

func (*S3) LoadEnv

func (d *S3) LoadEnv(prefix string) error

func (*S3) LoadFlags

func (d *S3) LoadFlags() error

type S3Op

type S3Op struct {
	Operation   S3Operation
	Bucket      string
	Key         string
	KeyTemplate string
}

func (*S3Op) GetKey

func (o *S3Op) GetKey() string

type S3Operation

type S3Operation string

type SQS

type SQS struct {
	Client        *sqs.SQS
	Queue         string
	ReceiptHandle string
	Region        string
	RoleARN       string
}

func (*SQS) Cleanup

func (d *SQS) Cleanup() error

func (*SQS) ClearWork

func (d *SQS) ClearWork() error

func (*SQS) GetWork

func (d *SQS) GetWork() (io.Reader, error)

func (*SQS) HandleFailure

func (d *SQS) HandleFailure() error

func (*SQS) Init

func (d *SQS) Init() error

func (*SQS) LoadEnv

func (d *SQS) LoadEnv(prefix string) error

func (*SQS) LoadFlags

func (d *SQS) LoadFlags() error