azure

package
v1.0.8 Latest Latest
Warning

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

 Go to latest Published: Oct 28, 2024 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Azure 

type Azure struct {
	backend.BackendUnsupported
	// contains filtered or unexported fields
}

func New 

func New(accountName, accountKey, serviceURL, sasToken string) (*Azure, error)

func (*Azure) AbortMultipartUpload 

func (az *Azure) AbortMultipartUpload(ctx context.Context, input *s3.AbortMultipartUploadInput) error

Deletes the block blob with committed/uncommitted blocks Cleans up the initiated multipart upload in .sgwtmp namespace

func (*Azure) ChangeBucketOwner 

func (az *Azure) ChangeBucketOwner(ctx context.Context, bucket string, acl []byte) error

func (*Azure) CompleteMultipartUpload 

func (az *Azure) CompleteMultipartUpload(ctx context.Context, input *s3.CompleteMultipartUploadInput) (*s3.CompleteMultipartUploadOutput, error)

Commits all the uncommitted blocks inside the block blob And moves the block blob from staging area into the blobs list. Copeies the multipart metadata from .sgwtmp namespace into the newly created blob Deletes the multipart upload 'blob' from .sgwtmp namespace It indicates the end of the multipart upload

func (*Azure) CopyObject 

func (az *Azure) CopyObject(ctx context.Context, input *s3.CopyObjectInput) (*s3.CopyObjectOutput, error)

func (*Azure) CreateBucket 

func (az *Azure) CreateBucket(ctx context.Context, input *s3.CreateBucketInput, acl []byte) error

func (*Azure) CreateMultipartUpload 

func (az *Azure) CreateMultipartUpload(ctx context.Context, input *s3.CreateMultipartUploadInput) (s3response.InitiateMultipartUploadResult, error)

func (*Azure) DeleteBucket 

func (az *Azure) DeleteBucket(ctx context.Context, bucket string) error

func (*Azure) DeleteBucketOwnershipControls added in v1.0.3 

func (az *Azure) DeleteBucketOwnershipControls(ctx context.Context, bucket string) error

func (*Azure) DeleteBucketPolicy 

func (az *Azure) DeleteBucketPolicy(ctx context.Context, bucket string) error

func (*Azure) DeleteBucketTagging 

func (az *Azure) DeleteBucketTagging(ctx context.Context, bucket string) error

func (*Azure) DeleteObject 

func (az *Azure) DeleteObject(ctx context.Context, input *s3.DeleteObjectInput) (*s3.DeleteObjectOutput, error)

func (*Azure) DeleteObjectTagging 

func (az *Azure) DeleteObjectTagging(ctx context.Context, bucket, object string) error

func (*Azure) DeleteObjects 

func (az *Azure) DeleteObjects(ctx context.Context, input *s3.DeleteObjectsInput) (s3response.DeleteResult, error)

func (*Azure) GetBucketAcl 

func (az *Azure) GetBucketAcl(ctx context.Context, input *s3.GetBucketAclInput) ([]byte, error)

func (*Azure) GetBucketOwnershipControls added in v1.0.3 

func (az *Azure) GetBucketOwnershipControls(ctx context.Context, bucket string) (types.ObjectOwnership, error)

func (*Azure) GetBucketPolicy 

func (az *Azure) GetBucketPolicy(ctx context.Context, bucket string) ([]byte, error)

func (*Azure) GetBucketTagging 

func (az *Azure) GetBucketTagging(ctx context.Context, bucket string) (map[string]string, error)

func (*Azure) GetObject 

func (az *Azure) GetObject(ctx context.Context, input *s3.GetObjectInput) (*s3.GetObjectOutput, error)

func (*Azure) GetObjectAttributes 

func (az *Azure) GetObjectAttributes(ctx context.Context, input *s3.GetObjectAttributesInput) (s3response.GetObjectAttributesResult, error)

func (*Azure) GetObjectLegalHold 

func (az *Azure) GetObjectLegalHold(ctx context.Context, bucket, object, versionId string) (*bool, error)

func (*Azure) GetObjectLockConfiguration 

func (az *Azure) GetObjectLockConfiguration(ctx context.Context, bucket string) ([]byte, error)

func (*Azure) GetObjectRetention 

func (az *Azure) GetObjectRetention(ctx context.Context, bucket, object, versionId string) ([]byte, error)

func (*Azure) GetObjectTagging 

func (az *Azure) GetObjectTagging(ctx context.Context, bucket, object string) (map[string]string, error)

func (*Azure) HeadBucket 

func (az *Azure) HeadBucket(ctx context.Context, input *s3.HeadBucketInput) (*s3.HeadBucketOutput, error)

func (*Azure) HeadObject 

func (az *Azure) HeadObject(ctx context.Context, input *s3.HeadObjectInput) (*s3.HeadObjectOutput, error)

func (*Azure) ListBuckets 

func (az *Azure) ListBuckets(ctx context.Context, owner string, isAdmin bool) (s3response.ListAllMyBucketsResult, error)

func (*Azure) ListBucketsAndOwners 

func (az *Azure) ListBucketsAndOwners(ctx context.Context) (buckets []s3response.Bucket, err error)

The action actually returns the containers owned by the user, who initialized the gateway TODO: Not sure if there's a way to list all the containers and owners?

func (*Azure) ListMultipartUploads 

func (az *Azure) ListMultipartUploads(ctx context.Context, input *s3.ListMultipartUploadsInput) (s3response.ListMultipartUploadsResult, error)

Lists all the multipart uploads initiated with .sgwtmp/multipart prefix

func (*Azure) ListObjects 

func (az *Azure) ListObjects(ctx context.Context, input *s3.ListObjectsInput) (s3response.ListObjectsResult, error)

func (*Azure) ListObjectsV2 

func (az *Azure) ListObjectsV2(ctx context.Context, input *s3.ListObjectsV2Input) (s3response.ListObjectsV2Result, error)

func (*Azure) ListParts 

func (az *Azure) ListParts(ctx context.Context, input *s3.ListPartsInput) (s3response.ListPartsResult, error)

Lists all uncommitted parts from the blob

func (*Azure) PutBucketAcl 

func (az *Azure) PutBucketAcl(ctx context.Context, bucket string, data []byte) error

func (*Azure) PutBucketOwnershipControls added in v1.0.3 

func (az *Azure) PutBucketOwnershipControls(ctx context.Context, bucket string, ownership types.ObjectOwnership) error

func (*Azure) PutBucketPolicy 

func (az *Azure) PutBucketPolicy(ctx context.Context, bucket string, policy []byte) error

func (*Azure) PutBucketTagging 

func (az *Azure) PutBucketTagging(ctx context.Context, bucket string, tags map[string]string) error

func (*Azure) PutObject 

func (az *Azure) PutObject(ctx context.Context, po *s3.PutObjectInput) (s3response.PutObjectOutput, error)

func (*Azure) PutObjectLegalHold 

func (az *Azure) PutObjectLegalHold(ctx context.Context, bucket, object, versionId string, status bool) error

func (*Azure) PutObjectLockConfiguration 

func (az *Azure) PutObjectLockConfiguration(ctx context.Context, bucket string, config []byte) error

func (*Azure) PutObjectRetention 

func (az *Azure) PutObjectRetention(ctx context.Context, bucket, object, versionId string, bypass bool, retention []byte) error

func (*Azure) PutObjectTagging 

func (az *Azure) PutObjectTagging(ctx context.Context, bucket, object string, tags map[string]string) error

func (*Azure) Shutdown 

func (az *Azure) Shutdown()

func (*Azure) String 

func (az *Azure) String() string

func (*Azure) UploadPart 

func (az *Azure) UploadPart(ctx context.Context, input *s3.UploadPartInput) (etag string, err error)

Each part is translated into an uncommitted block in a newly created blob in staging area

func (*Azure) UploadPartCopy 

func (az *Azure) UploadPartCopy(ctx context.Context, input *s3.UploadPartCopyInput) (s3response.CopyObjectResult, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.