Documentation
¶
Index ¶
- Constants
- func MapOwnersACL(srcOwner *awss3.Owner, srcGrants []*awss3.Grant, dstOwner *string, ...) *awss3.AccessControlPolicy
- type Bucket
- type CopySvc
- type File
- type ObjectInfo
- type S3CopySvc
- func (r *S3CopySvc) CopyACLs(ctx context.Context, user string, from File, to File) error
- func (r *S3CopySvc) CopyObject(ctx context.Context, user string, from File, to File) error
- func (r *S3CopySvc) DeleteDestinationObject(ctx context.Context, user string, to File) error
- func (r *S3CopySvc) GetLastMigratedVersionInfo(ctx context.Context, user string, to File) (entity.ObjectVersionInfo, error)
- func (r *S3CopySvc) GetVersionInfo(ctx context.Context, user string, to File) ([]entity.ObjectVersionInfo, error)
Constants ¶
View Source
const ( CChorusSourceVersionIDMetaHeader = "x-amz-meta-chorus-source-version-id" CRGWVersionMigrationQueryParam = "rgwx-version-id" )
TODO: swift client metrics
Variables ¶
This section is empty.
Functions ¶
func MapOwnersACL ¶
Types ¶
type CopySvc ¶
type CopySvc interface {
GetVersionInfo(ctx context.Context, user string, to File) ([]entity.ObjectVersionInfo, error)
DeleteDestinationObject(ctx context.Context, user string, to File) error
GetLastMigratedVersionInfo(ctx context.Context, user string, to File) (entity.ObjectVersionInfo, error)
CopyObject(ctx context.Context, user string, from File, to File) error
CopyACLs(ctx context.Context, user string, from File, to File) error
}
type ObjectInfo ¶
type S3CopySvc ¶
type S3CopySvc struct {
// contains filtered or unexported fields
}
func NewS3CopySvc ¶
func NewS3CopySvc(credsSvc objstore.CredsService, clientRegistry objstore.Clients, metricsSvc metrics.WorkerService) *S3CopySvc
func (*S3CopySvc) CopyObject ¶
func (*S3CopySvc) DeleteDestinationObject ¶
func (*S3CopySvc) GetLastMigratedVersionInfo ¶
func (*S3CopySvc) GetVersionInfo ¶
Click to show internal directories.
Click to hide internal directories.