Documentation
¶
Index ¶
- Constants
- func MapOwnersACL(srcOwner *awss3.Owner, srcGrants []*awss3.Grant, dstOwner *string, ...) *awss3.AccessControlPolicy
- func WithAfter(after string) func(o *minio.ListObjectsOptions)
- func WithPrefix(prefix string) func(o *minio.ListObjectsOptions)
- func WithVersions() func(o *minio.ListObjectsOptions)
- type Bucket
- type CopySvc
- type File
- type ObjectInfo
- type S3CopySvc
- func (r *S3CopySvc) BucketObjects(ctx context.Context, user string, bucket Bucket, ...) iter.Seq2[ObjectInfo, error]
- 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)
- func (r *S3CopySvc) IsBucketVersioned(ctx context.Context, user string, bucket Bucket) (bool, 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 ¶
func WithAfter ¶
func WithAfter(after string) func(o *minio.ListObjectsOptions)
func WithPrefix ¶
func WithPrefix(prefix string) func(o *minio.ListObjectsOptions)
func WithVersions ¶
func WithVersions() func(o *minio.ListObjectsOptions)
Types ¶
type CopySvc ¶
type CopySvc interface {
BucketObjects(ctx context.Context, user string, bucket Bucket, opts ...func(o *minio.ListObjectsOptions)) iter.Seq2[ObjectInfo, error]
IsBucketVersioned(ctx context.Context, user string, bucket Bucket) (bool, error)
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) BucketObjects ¶
func (*S3CopySvc) CopyObject ¶
func (*S3CopySvc) DeleteDestinationObject ¶
func (*S3CopySvc) GetLastMigratedVersionInfo ¶
func (*S3CopySvc) GetVersionInfo ¶
Click to show internal directories.
Click to hide internal directories.