azure

package
v1.0.1 Latest Latest
Warning

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

 Go to latest Published: Jun 11, 2024 License: Apache-2.0 Imports: 27 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

func (*Azure) ChangeBucketOwner 

func (az *Azure) ChangeBucketOwner(ctx context.Context, bucket, newOwner string) 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 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) (*s3.CreateMultipartUploadOutput, error)

func (*Azure) DeleteBucket 

func (az *Azure) DeleteBucket(ctx context.Context, input *s3.DeleteBucketInput) 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) 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) 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, writer io.Writer) (*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 block blobs, which has uncommitted blocks

func (*Azure) ListObjects 

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

func (*Azure) ListObjectsV2 

func (az *Azure) ListObjectsV2(ctx context.Context, input *s3.ListObjectsV2Input) (*s3.ListObjectsV2Output, 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) 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) (string, 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.