aws

package
v0.0.65 Latest Latest
Warning

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

Go to latest
Published: Oct 21, 2022 License: MIT Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

This section is empty.

Types

type Dynamo

type Dynamo struct {
	Client *dynamodb.DynamoDB

	Region           string
	RetrieveField    *string
	Limit            *int64
	NextToken        *string
	IncludeNextToken bool
	UnmarshalJSON    bool
	RoleARN          string
	RetrieveQuery    *string
	ClearQuery       *string
	FailQuery        *string
	// contains filtered or unexported fields
}

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

func (*Dynamo) LogIdentity added in v0.0.27

func (d *Dynamo) LogIdentity() error

type S3 added in v0.0.22

type S3 struct {
	Client *s3.S3

	Bucket    string
	Key       string
	KeyRegex  string
	KeyPrefix string
	Region    string
	RoleARN   string
	ClearOp   *S3Op
	FailOp    *S3Op
	// contains filtered or unexported fields
}

func (*S3) Cleanup added in v0.0.22

func (d *S3) Cleanup() error

func (*S3) ClearWork added in v0.0.22

func (d *S3) ClearWork() error

func (*S3) GetWork added in v0.0.22

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

func (*S3) HandleFailure added in v0.0.22

func (d *S3) HandleFailure() error

func (*S3) Init added in v0.0.22

func (d *S3) Init() error

func (*S3) LoadEnv added in v0.0.22

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

func (*S3) LoadFlags added in v0.0.22

func (d *S3) LoadFlags() error

func (*S3) LogIdentity added in v0.0.27

func (d *S3) LogIdentity() error

type S3Op added in v0.0.22

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

func (*S3Op) GetKey added in v0.0.22

func (o *S3Op) GetKey() string

type S3Operation added in v0.0.22

type S3Operation string

type SQS

type SQS struct {
	Client *sqs.SQS

	Queue         string
	ReceiptHandle string
	Region        string
	RoleARN       string
	IncludeID     bool
	// contains filtered or unexported fields
}

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

func (*SQS) LogIdentity added in v0.0.26

func (d *SQS) LogIdentity() error

type STSSession added in v0.0.26

type STSSession struct {
	Session *session.Session
	Config  *aws.Config
}

Jump to

Keyboard shortcuts

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