s3

Documentation

Index

• type AwsClient
• type Bucket
  • func NewBucket(client AwsClient, bucket types.Bucket, tags []types.Tag) Bucket
  • func (e Bucket) GetName() string
  • func (e Bucket) GetTagValue(tag string) string
  • func (e Bucket) GetTags() map[string]string
• type BucketList
• type S3Repository
  • func NewS3Repository(ctx context.Context, client AwsClient) *S3Repository
  • func (r *S3Repository) GetRegion() ptypes.AwsRegion
  • func (r *S3Repository) GetTags(bucket types.Bucket) ([]types.Tag, error)
  • func (r *S3Repository) ListBucketsAll() ([]Bucket, error)
  • func (r *S3Repository) ListBucketsByInput(query *s3.ListBucketsInput) ([]Bucket, error)

Types

type AwsClient

type AwsClient interface {
	GetRegion() ptypes.AwsRegion
	GetAccountID() ptypes.AwsAccountID
	S3(optFns ...func(o *s3.Options)) *s3.Client
}

type Bucket

type Bucket struct {
	service.AbstractResource
	types.Bucket
	Tags []types.Tag
}

func NewBucket

func NewBucket(client AwsClient, bucket types.Bucket, tags []types.Tag) Bucket

func (Bucket) GetName

func (e Bucket) GetName() string

func (Bucket) GetTagValue

func (e Bucket) GetTagValue(tag string) string

func (Bucket) GetTags

func (e Bucket) GetTags() map[string]string

type BucketList

type BucketList struct {
	Items []Bucket
}

type S3Repository

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

func NewS3Repository

func NewS3Repository(ctx context.Context, client AwsClient) *S3Repository

func (*S3Repository) GetRegion

func (r *S3Repository) GetRegion() ptypes.AwsRegion

func (*S3Repository) GetTags

func (r *S3Repository) GetTags(bucket types.Bucket) ([]types.Tag, error)

func (*S3Repository) ListBucketsAll

func (r *S3Repository) ListBucketsAll() ([]Bucket, error)

func (*S3Repository) ListBucketsByInput

func (r *S3Repository) ListBucketsByInput(query *s3.ListBucketsInput) ([]Bucket, error)