drh

package

Go to main page

Versions in this module

v1

v1.0.2

Apr 22, 2021

v1.0.1

Apr 21, 2021

Changes in this version

type JobConfig

+ DestAcl string

+ SrcEndpoint string

v1.0.0

Mar 15, 2021

Changes in this version

+ const Delete

+ const Ignore

+ const MaxRetries

+ const Transfer

type Client

+ DeleteObject func(ctx context.Context, key *string) (err error)

+ GetUploadID func(ctx context.Context, key *string) (uploadID *string)

type DBService

+ func (db *DBService) PutItem(ctx context.Context, o *Object) error

+ func (db *DBService) QueryItem(ctx context.Context, key *string) (*Item, error)

+ func (db *DBService) UpdateItem(ctx context.Context, key *string, result *TransferResult) error

+ func (db *DBService) UpdateSequencer(ctx context.Context, key, sequencer *string) error

type Item

+ EndTimestamp int64

+ Etag string

+ JobStatus string

+ Sequencer string

+ SpentTime int64

+ StartTimestamp int64

type JobConfig

+ DestBucket string

+ DestPrefix string

+ SrcBucket string

+ SrcPrefix string

type JobOptions

+ IncludeMetadata bool

type Metadata

+ CacheControl *string

+ ContentEncoding *string

+ ContentLanguage *string

+ Metadata map[string]string

type Object

+ Sequencer string

type S3Client

+ func (c *S3Client) DeleteObject(ctx context.Context, key *string) (err error)

+ func (c *S3Client) GetUploadID(ctx context.Context, key *string) (uploadID *string)

+ type S3Event struct

+ Records []struct{ ... }

v0

v0.1.0

Feb 25, 2021

Changes in this version

+ const DefaultChunkSize

+ const DefaultFinderDepth

+ const DefaultFinderNumber

+ const DefaultMaxKeys

+ const DefaultMaxParts

+ const DefaultMessageBatchSize

+ const DefaultMultipartThreshold

+ const DefaultWorkerNumber

+ var KB int = 1 << 10

+ var MB int = 1 << 20

+ type Client interface

+ AbortMultipartUpload func(key string, uploadID *string)

+ CompleteMultipartUpload func(key string, uploadID *string, parts []*Part) (etag *string, err error)

+ CreateMultipartUpload func(key string) (uploadID *string, err error)

+ GetObject func(key string, size, start, chunkSize int64, version string) ([]byte, error)

+ HeadObject func(key string)

+ ListCommonPrefixes func(depth int, maxKeys int32) (prefixes []*string)

+ ListMultipartUploads func(key string)

+ ListObjects func(continuationToken, prefix *string, maxKeys int32) ([]*Object, error)

+ ListParts func(key, uploadID string)

+ PutObject func(key string, body []byte, storageClass string) (etag *string, err error)

+ UploadPart func(key string, uploadID *string, body []byte, partNumber int) (etag *string, err error)

+ type DBService struct

+ func NewDBService(ctx context.Context, tableName string) (*DBService, error)

+ type Finder struct

+ func NewFinder(ctx context.Context, cfg *JobConfig) (f *Finder)

+ func (f *Finder) Run()

+ type Item struct

+ DesBucket string

+ DesKey string

+ EndTime int

+ ExtraInfo Metadata

+ ObjectKey string

+ Size int64

+ StartTime int

+ Status string

+ StorageClass string

+ Version string

+ type Job interface

+ Run func()

+ type JobConfig struct

+ DestBucketName string

+ DestBucketPrefix string

+ DestCredential string

+ DestInCurrentAccount bool

+ DestRegion string

+ DestStorageClass string

+ JobQueueName string

+ JobTableName string

+ SrcBucketName string

+ SrcBucketPrefix string

+ SrcCredential string

+ SrcInCurrentAccount bool

+ SrcRegion string

+ SrcType string

+ type JobOptions struct

+ ChunkSize int

+ FinderDepth int

+ FinderNumber int

+ MaxKeys int32

+ MessageBatchSize int

+ MultipartThreshold int

+ WorkerNumber int

+ type Message struct

+ Key string

+ Size int64

+ Version string

+ type Metadata struct

+ ContentType string

+ type Object struct

+ Key string

+ Size int64

+ type Part struct

+ type S3Client struct

+ func NewS3Client(ctx context.Context, bucket, prefix, region, sourceType string, ...) *S3Client

+ func (c *S3Client) AbortMultipartUpload(key string, uploadID *string)

+ func (c *S3Client) CompleteMultipartUpload(key string, uploadID *string, parts []*Part) (etag *string, err error)

+ func (c *S3Client) CreateMultipartUpload(key string) (uploadID *string, err error)

+ func (c *S3Client) GetObject(key string, size, start, chunkSize int64, version string) ([]byte, error)

+ func (c *S3Client) HeadObject(key string)

+ func (c *S3Client) ListCommonPrefixes(depth int, maxKeys int32) (prefixes []*string)

+ func (c *S3Client) ListMultipartUploads(key string)

+ func (c *S3Client) ListObjects(continuationToken, prefix *string, maxKeys int32) ([]*Object, error)

+ func (c *S3Client) ListParts(key, uploadID string)

+ func (c *S3Client) PutObject(key string, body []byte, storageClass string) (etag *string, err error)

+ func (c *S3Client) UploadPart(key string, uploadID *string, body []byte, partNumber int) (etag *string, err error)

+ type S3Credentials struct

+ type SqsService struct

+ func NewSqsService(ctx context.Context, queueName string) (*SqsService, error)

+ func (ss *SqsService) ChangeVisibilityTimeout(rh *string, seconds int32) (ok bool)

+ func (ss *SqsService) DeleteMessage(rh *string) (ok bool)

+ func (ss *SqsService) IsQueueEmpty() bool

+ func (ss *SqsService) ReceiveMessages() (obj *Object, receiptHandle *string)

+ func (ss *SqsService) SendMessage(o *Object) error

+ func (ss *SqsService) SendMessageInBatch(batch []*Object)

+ type SsmService struct

+ func NewSsmService(ctx context.Context) (*SsmService, error)

+ func (s *SsmService) GetParameterValue(param *string, withDecryption bool) *string

+ type TransferResult struct

+ type Worker struct

+ func NewWorker(ctx context.Context, cfg *JobConfig) (w *Worker)

+ func (w *Worker) Run()

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