clients

Documentation

Index

• Constants
• type AWSClient
  • func NewAWSClient(keyID, key, region string) (*AWSClient, error)
  • func (ac *AWSClient) AbortMultipartUpload(request *UploadRequest) error
  • func (ac *AWSClient) CompleteMultipartUpload(request *UploadRequest, parts []*types.PartInfo, checksum string) error
  • func (ac *AWSClient) CreateMultipartUpload(bucket, remotePath, fileType, storageClass string) (*UploadRequest, error)
  • func (ac *AWSClient) GetObject(ctx context.Context, bucket, remotePath string, writer io.Writer) (int64, error)
  • func (ac *AWSClient) HeadObject(bucket, remotePath string) (*types.ISOInfo, error)
  • func (ac *AWSClient) ListMultipartUploads(bucket string) ([]*UploadRequest, error)
  • func (ac *AWSClient) PutObject(bucket, remotePath, checksum, fileType, storageClass string, ...) error
  • func (ac *AWSClient) Upload(partNo, length int64, request *UploadRequest, reader io.ReadSeeker, ...) (string, error)
• type UploadRequest

Constants

const (
	S3    = 1
	Minio = 2
)

Types

type AWSClient

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

func NewAWSClient

func NewAWSClient(keyID, key, region string) (*AWSClient, error)

func (*AWSClient) AbortMultipartUpload

func (ac *AWSClient) AbortMultipartUpload(request *UploadRequest) error

func (*AWSClient) CompleteMultipartUpload

func (ac *AWSClient) CompleteMultipartUpload(request *UploadRequest, parts []*types.PartInfo, checksum string) error

func (*AWSClient) CreateMultipartUpload

func (ac *AWSClient) CreateMultipartUpload(bucket, remotePath, fileType, storageClass string) (*UploadRequest, error)

func (*AWSClient) GetObject

func (ac *AWSClient) GetObject(ctx context.Context, bucket, remotePath string, writer io.Writer) (int64, error)

func (*AWSClient) HeadObject

func (ac *AWSClient) HeadObject(bucket, remotePath string) (*types.ISOInfo, error)

func (*AWSClient) ListMultipartUploads

func (ac *AWSClient) ListMultipartUploads(bucket string) ([]*UploadRequest, error)

func (*AWSClient) PutObject

func (ac *AWSClient) PutObject(bucket, remotePath, checksum, fileType, storageClass string, reader io.ReadSeeker) error

func (*AWSClient) Upload

func (ac *AWSClient) Upload(partNo, length int64, request *UploadRequest, reader io.ReadSeeker,
	checksum string) (string, error)

type UploadRequest

type UploadRequest struct {
	Time   time.Time
	ID     string
	Bucket string
	Key    string
}