aws

package
v1.10.0 Latest Latest
Warning

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

Go to latest
Published: Feb 14, 2024 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BucketList

func BucketList(sess *session.Session) ([]*model.MetaBucket, error)

func GetBucketMeta

func GetBucketMeta(buckIdx int, bucket *s3.Bucket, sess *session.Session, bucketArray []*model.MetaBucket, wg *sync.WaitGroup)

func GetHeadObject

func GetHeadObject(sess *session.Session, bucketName *string, obj *model.MetaObject)

func ObjectList

func ObjectList(sess *session.Session, bucket *model.MetaBucket) error

Types

type AwsAdapter

type AwsAdapter struct {
	Backend *backendpb.BackendDetail
	Session *session.Session
}

func (*AwsAdapter) DownloadObject

func (ad *AwsAdapter) DownloadObject()

func (*AwsAdapter) SyncMetadata

func (ad *AwsAdapter) SyncMetadata(ctx context.Context, in *pb.SyncMetadataRequest) error

type AwsS3DriverFactory

type AwsS3DriverFactory struct {
}

func (*AwsS3DriverFactory) CreateDriver

func (factory *AwsS3DriverFactory) CreateDriver(backend *backendpb.BackendDetail) (driver.CloudDriver, error)

type S3Cred

type S3Cred struct {
	Ak string
	Sk string
}

func (*S3Cred) IsExpired

func (myc *S3Cred) IsExpired() bool

func (*S3Cred) Retrieve

func (myc *S3Cred) Retrieve() (credentials.Value, error)

Jump to

Keyboard shortcuts

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