s3proxy

Documentation

Index

• type S3Proxy
  • func New(access, secret, endpoint, region string, ...) (*S3Proxy, error)
  • func (s *S3Proxy) AbortMultipartUpload(ctx context.Context, input *s3.AbortMultipartUploadInput) error
  • func (s *S3Proxy) ChangeBucketOwner(ctx context.Context, bucket, newOwner string) error
  • func (s *S3Proxy) CompleteMultipartUpload(ctx context.Context, input *s3.CompleteMultipartUploadInput) (*s3.CompleteMultipartUploadOutput, error)
  • func (s *S3Proxy) CopyObject(ctx context.Context, input *s3.CopyObjectInput) (*s3.CopyObjectOutput, error)
  • func (s *S3Proxy) CreateBucket(ctx context.Context, input *s3.CreateBucketInput, acl []byte) error
  • func (s *S3Proxy) CreateMultipartUpload(ctx context.Context, input *s3.CreateMultipartUploadInput) (*s3.CreateMultipartUploadOutput, error)
  • func (s *S3Proxy) DeleteBucket(ctx context.Context, input *s3.DeleteBucketInput) error
  • func (s *S3Proxy) DeleteObject(ctx context.Context, input *s3.DeleteObjectInput) error
  • func (s *S3Proxy) DeleteObjectTagging(ctx context.Context, bucket, object string) error
  • func (s *S3Proxy) DeleteObjects(ctx context.Context, input *s3.DeleteObjectsInput) (s3response.DeleteResult, error)
  • func (s *S3Proxy) GetBucketAcl(ctx context.Context, input *s3.GetBucketAclInput) ([]byte, error)
  • func (s *S3Proxy) GetObject(ctx context.Context, input *s3.GetObjectInput, w io.Writer) (*s3.GetObjectOutput, error)
  • func (s *S3Proxy) GetObjectAttributes(ctx context.Context, input *s3.GetObjectAttributesInput) (*s3.GetObjectAttributesOutput, error)
  • func (s *S3Proxy) GetObjectTagging(ctx context.Context, bucket, object string) (map[string]string, error)
  • func (s *S3Proxy) HeadBucket(ctx context.Context, input *s3.HeadBucketInput) (*s3.HeadBucketOutput, error)
  • func (s *S3Proxy) HeadObject(ctx context.Context, input *s3.HeadObjectInput) (*s3.HeadObjectOutput, error)
  • func (s *S3Proxy) ListBuckets(ctx context.Context, owner string, isAdmin bool) (s3response.ListAllMyBucketsResult, error)
  • func (s *S3Proxy) ListBucketsAndOwners(ctx context.Context) ([]s3response.Bucket, error)
  • func (s *S3Proxy) ListMultipartUploads(ctx context.Context, input *s3.ListMultipartUploadsInput) (s3response.ListMultipartUploadsResult, error)
  • func (s *S3Proxy) ListObjects(ctx context.Context, input *s3.ListObjectsInput) (*s3.ListObjectsOutput, error)
  • func (s *S3Proxy) ListObjectsV2(ctx context.Context, input *s3.ListObjectsV2Input) (*s3.ListObjectsV2Output, error)
  • func (s *S3Proxy) ListParts(ctx context.Context, input *s3.ListPartsInput) (s3response.ListPartsResult, error)
  • func (s *S3Proxy) PutBucketAcl(ctx context.Context, bucket string, data []byte) error
  • func (s *S3Proxy) PutObject(ctx context.Context, input *s3.PutObjectInput) (string, error)
  • func (s *S3Proxy) PutObjectTagging(ctx context.Context, bucket, object string, tags map[string]string) error
  • func (s *S3Proxy) ResolveEndpoint(service, region string, options ...interface{}) (aws.Endpoint, error)
  • func (s *S3Proxy) UploadPart(ctx context.Context, input *s3.UploadPartInput) (etag string, err error)
  • func (s *S3Proxy) UploadPartCopy(ctx context.Context, input *s3.UploadPartCopyInput) (s3response.CopyObjectResult, error)

Types

type S3Proxy

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

func New

func New(access, secret, endpoint, region string, disableChecksum, sslSkipVerify, debug bool) (*S3Proxy, error)

func (*S3Proxy) AbortMultipartUpload

func (s *S3Proxy) AbortMultipartUpload(ctx context.Context, input *s3.AbortMultipartUploadInput) error

func (*S3Proxy) ChangeBucketOwner

func (s *S3Proxy) ChangeBucketOwner(ctx context.Context, bucket, newOwner string) error

func (*S3Proxy) CompleteMultipartUpload

func (s *S3Proxy) CompleteMultipartUpload(ctx context.Context, input *s3.CompleteMultipartUploadInput) (*s3.CompleteMultipartUploadOutput, error)

func (*S3Proxy) CopyObject

func (s *S3Proxy) CopyObject(ctx context.Context, input *s3.CopyObjectInput) (*s3.CopyObjectOutput, error)

func (*S3Proxy) CreateBucket

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

func (*S3Proxy) CreateMultipartUpload

func (s *S3Proxy) CreateMultipartUpload(ctx context.Context, input *s3.CreateMultipartUploadInput) (*s3.CreateMultipartUploadOutput, error)

func (*S3Proxy) DeleteBucket

func (s *S3Proxy) DeleteBucket(ctx context.Context, input *s3.DeleteBucketInput) error

func (*S3Proxy) DeleteObject

func (s *S3Proxy) DeleteObject(ctx context.Context, input *s3.DeleteObjectInput) error

func (*S3Proxy) DeleteObjectTagging

func (s *S3Proxy) DeleteObjectTagging(ctx context.Context, bucket, object string) error

func (*S3Proxy) DeleteObjects

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

func (*S3Proxy) GetBucketAcl

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

func (*S3Proxy) GetObject

func (s *S3Proxy) GetObject(ctx context.Context, input *s3.GetObjectInput, w io.Writer) (*s3.GetObjectOutput, error)

func (*S3Proxy) GetObjectAttributes

func (s *S3Proxy) GetObjectAttributes(ctx context.Context, input *s3.GetObjectAttributesInput) (*s3.GetObjectAttributesOutput, error)

func (*S3Proxy) GetObjectTagging

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

func (*S3Proxy) HeadBucket

func (s *S3Proxy) HeadBucket(ctx context.Context, input *s3.HeadBucketInput) (*s3.HeadBucketOutput, error)

func (*S3Proxy) HeadObject

func (s *S3Proxy) HeadObject(ctx context.Context, input *s3.HeadObjectInput) (*s3.HeadObjectOutput, error)

func (*S3Proxy) ListBuckets

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

func (*S3Proxy) ListBucketsAndOwners

func (s *S3Proxy) ListBucketsAndOwners(ctx context.Context) ([]s3response.Bucket, error)

func (*S3Proxy) ListMultipartUploads

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

func (*S3Proxy) ListObjects

func (s *S3Proxy) ListObjects(ctx context.Context, input *s3.ListObjectsInput) (*s3.ListObjectsOutput, error)

func (*S3Proxy) ListObjectsV2

func (s *S3Proxy) ListObjectsV2(ctx context.Context, input *s3.ListObjectsV2Input) (*s3.ListObjectsV2Output, error)

func (*S3Proxy) ListParts

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

func (*S3Proxy) PutBucketAcl

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

func (*S3Proxy) PutObject

func (s *S3Proxy) PutObject(ctx context.Context, input *s3.PutObjectInput) (string, error)

func (*S3Proxy) PutObjectTagging

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

func (*S3Proxy) ResolveEndpoint

func (s *S3Proxy) ResolveEndpoint(service, region string, options ...interface{}) (aws.Endpoint, error)

ResolveEndpoint is used for on prem or non-aws endpoints

func (*S3Proxy) UploadPart

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

func (*S3Proxy) UploadPartCopy

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