azure

package
v0.3.2 Latest Latest
Warning

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

Go to latest
Published: Nov 9, 2018 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var MaxTimeForSingleHttpRequest = 50 * time.Minute

TryTimeout indicates the maximum time allowed for any single try of an HTTP request.

Functions

This section is empty.

Types

type AzureAdapter

type AzureAdapter struct {
	// contains filtered or unexported fields
}

func Init

func Init(backend *backendpb.BackendDetail) *AzureAdapter

func (*AzureAdapter) AbortMultipartUpload

func (ad *AzureAdapter) AbortMultipartUpload(multipartUpload *pb.MultipartUpload, context context.Context) S3Error

func (*AzureAdapter) Base64ToInt64

func (ad *AzureAdapter) Base64ToInt64(base64ID string) int64

func (*AzureAdapter) BinaryToBase64

func (ad *AzureAdapter) BinaryToBase64(binaryID []byte) string

func (*AzureAdapter) CompleteMultipartUpload

func (ad *AzureAdapter) CompleteMultipartUpload(
	multipartUpload *pb.MultipartUpload,
	completeUpload *model.CompleteMultipartUpload,
	context context.Context) (*model.CompleteMultipartUploadResult, S3Error)

func (*AzureAdapter) DELETE

func (ad *AzureAdapter) DELETE(object *pb.DeleteObjectInput, ctx context.Context) S3Error

func (*AzureAdapter) GET

func (ad *AzureAdapter) GET(object *pb.Object, context context.Context) (io.ReadCloser, S3Error)

func (*AzureAdapter) GetObjectInfo

func (ad *AzureAdapter) GetObjectInfo(bucketName string, key string, context context.Context) (*pb.Object, S3Error)

func (*AzureAdapter) InitMultipartUpload

func (ad *AzureAdapter) InitMultipartUpload(object *pb.Object, context context.Context) (*pb.MultipartUpload, S3Error)

func (*AzureAdapter) Int64ToBase64

func (ad *AzureAdapter) Int64ToBase64(blockID int64) string

func (*AzureAdapter) ListParts

func (ad *AzureAdapter) ListParts(listParts *pb.ListParts, context context.Context) (*model.ListPartsOutput, S3Error)

func (*AzureAdapter) PUT

func (ad *AzureAdapter) PUT(stream io.Reader, object *pb.Object, ctx context.Context) S3Error

func (*AzureAdapter) UploadPart

func (ad *AzureAdapter) UploadPart(stream io.Reader, multipartUpload *pb.MultipartUpload, partNumber int64, upBytes int64, context context.Context) (*model.UploadPartResult, S3Error)

Jump to

Keyboard shortcuts

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