s3client

package
v0.7.1 Latest Latest
Warning

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

 Go to latest Published: Feb 5, 2026 License: Apache-2.0 Imports: 28 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AwsErrRetry 

func AwsErrRetry(err error) bool

func ExtractReqBody 

func ExtractReqBody(r *http.Request, body any) error

func ExtractRespBody 

func ExtractRespBody(r *http.Response, body any) error

Types

type AWS 

type AWS struct {
	*aws_s3.S3
	// contains filtered or unexported fields
}

func (*AWS) CreateBucketWithContext added in v0.7.0 

func (s *AWS) CreateBucketWithContext(ctx aws.Context, input *aws_s3.CreateBucketInput, opts ...request.Option) (*aws_s3.CreateBucketOutput, error)

func (*AWS) GetBucketAclWithContext added in v0.7.0 

func (s *AWS) GetBucketAclWithContext(ctx aws.Context, input *aws_s3.GetBucketAclInput, opts ...request.Option) (*aws_s3.GetBucketAclOutput, error)

func (*AWS) GetObjectAclWithContext added in v0.7.0 

func (s *AWS) GetObjectAclWithContext(ctx aws.Context, input *aws_s3.GetObjectAclInput, opts ...request.Option) (*aws_s3.GetObjectAclOutput, error)

func (*AWS) HeadBucketWithContext added in v0.7.0 

func (s *AWS) HeadBucketWithContext(ctx aws.Context, input *aws_s3.HeadBucketInput, opts ...request.Option) (*aws_s3.HeadBucketOutput, error)

func (*AWS) PutBucketAclWithContext added in v0.7.0 

func (s *AWS) PutBucketAclWithContext(ctx aws.Context, input *aws_s3.PutBucketAclInput, opts ...request.Option) (*aws_s3.PutBucketAclOutput, error)

func (*AWS) PutObjectAclWithContext added in v0.7.0 

func (s *AWS) PutObjectAclWithContext(ctx aws.Context, input *aws_s3.PutObjectAclInput, opts ...request.Option) (*aws_s3.PutObjectAclOutput, error)

type Client 

type Client interface {
	S3() *S3
	AWS() *AWS
	SNS() *sns.Client
	Do(req *http.Request) (*http.Response, bool, error)
}

func NewClient added in v0.7.0 

func NewClient(ctx context.Context, metricsSvc metrics.Service, storageConf s3.StorageAddress, cred s3.CredentialsV4, storageName, userName string) (Client, error)

type RequestID 

type RequestID struct {
	ID       string
	Extended string
}

func GetRequestID 

func GetRequestID(resp *http.Response) (RequestID, error)

func MustRequestID 

func MustRequestID(resp *http.Response) RequestID

func (RequestID) String 

func (r RequestID) String() string

type S3 

type S3 struct {
	*mclient.Client
	// contains filtered or unexported fields
}

func (*S3) BucketExists 

func (s *S3) BucketExists(ctx context.Context, bucketName string) (bool, error)

func (*S3) GetBucketLifecycle 

func (s *S3) GetBucketLifecycle(ctx context.Context, bucketName string) (*lifecycle.Configuration, error)

func (*S3) GetBucketPolicy 

func (s *S3) GetBucketPolicy(ctx context.Context, bucketName string) (string, error)

func (*S3) GetBucketTagging 

func (s *S3) GetBucketTagging(ctx context.Context, bucketName string) (*tags.Tags, error)

func (*S3) GetBucketVersioning 

func (s *S3) GetBucketVersioning(ctx context.Context, bucketName string) (mclient.BucketVersioningConfiguration, error)

func (*S3) GetObject added in v0.7.0 

func (s *S3) GetObject(ctx context.Context, bucketName, objectName string, opts mclient.GetObjectOptions) (*mclient.Object, error)

func (*S3) GetObjectTagging 

func (s *S3) GetObjectTagging(ctx context.Context, bucketName, objectName string, opts mclient.GetObjectTaggingOptions) (*tags.Tags, error)

func (*S3) ListBuckets 

func (s *S3) ListBuckets(ctx context.Context) ([]mclient.BucketInfo, error)

func (*S3) ListObjects 

func (s *S3) ListObjects(ctx context.Context, bucketName string, opts mclient.ListObjectsOptions) <-chan mclient.ObjectInfo

func (*S3) MakeBucket 

func (s *S3) MakeBucket(ctx context.Context, bucketName string, opts mclient.MakeBucketOptions) (err error)

func (*S3) PutObject added in v0.7.0 

func (s *S3) PutObject(ctx context.Context, bucketName, objectName string, reader io.Reader, size int64, opts mclient.PutObjectOptions) (info mclient.UploadInfo, err error)

func (*S3) PutObjectTagging 

func (s *S3) PutObjectTagging(ctx context.Context, bucketName, objectName string, otags *tags.Tags, opts mclient.PutObjectTaggingOptions) error

func (*S3) RemoveBucket 

func (s *S3) RemoveBucket(ctx context.Context, bucketName string) error

func (*S3) RemoveBucketTagging 

func (s *S3) RemoveBucketTagging(ctx context.Context, bucketName string) error

func (*S3) RemoveObject 

func (s *S3) RemoveObject(ctx context.Context, bucketName, objectName string, opts mclient.RemoveObjectOptions) error

func (*S3) RemoveObjectTagging 

func (s *S3) RemoveObjectTagging(ctx context.Context, bucketName, objectName string, opts mclient.RemoveObjectTaggingOptions) error

func (*S3) RemoveObjects 

func (s *S3) RemoveObjects(ctx context.Context, bucketName string, objectsCh <-chan mclient.ObjectInfo, opts mclient.RemoveObjectsOptions) <-chan mclient.RemoveObjectError

func (*S3) SetBucketLifecycle 

func (s *S3) SetBucketLifecycle(ctx context.Context, bucketName string, config *lifecycle.Configuration) error

func (*S3) SetBucketPolicy 

func (s *S3) SetBucketPolicy(ctx context.Context, bucketName, policy string) error

func (*S3) SetBucketTagging 

func (s *S3) SetBucketTagging(ctx context.Context, bucketName string, tags *tags.Tags) error

func (*S3) SetBucketVersioning 

func (s *S3) SetBucketVersioning(ctx context.Context, bucketName string, config mclient.BucketVersioningConfiguration) error

func (*S3) StatObject added in v0.7.0 

func (s *S3) StatObject(ctx context.Context, bucketName, objectName string, opts mclient.StatObjectOptions) (mclient.ObjectInfo, 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.