Documentation
¶
Index ¶
- Constants
- Variables
- func BucketExists(ctx context.Context, s3Backend backendstore.S3Client, bucketName string) (bool, error)
- func BucketToCreateBucketInput(bucket *v1alpha1.Bucket) *s3.CreateBucketInput
- func BucketToPutBucketACLInput(bucket *v1alpha1.Bucket) *s3.PutBucketAclInput
- func BucketToPutBucketOwnershipControlsInput(bucket *v1alpha1.Bucket) *s3.PutBucketOwnershipControlsInput
- func CreateBucket(ctx context.Context, s3Backend backendstore.S3Client, ...) (*awss3.CreateBucketOutput, error)
- func DeleteBucket(ctx context.Context, s3Backend backendstore.S3Client, bucketName *string) error
- func DeleteBucketLifecycle(ctx context.Context, s3Backend backendstore.S3Client, bucketName *string) error
- func DeleteObject(ctx context.Context, s3Backend backendstore.S3Client, ...) error
- func GenerateLifecycleConfigurationInput(name string, config *v1alpha1.BucketLifecycleConfiguration) *awss3.PutBucketLifecycleConfigurationInput
- func GenerateLifecycleRules(in []v1alpha1.LifecycleRule) []types.LifecycleRule
- func GetBucketLifecycleConfiguration(ctx context.Context, s3Backend backendstore.S3Client, bucketName *string) (*awss3.GetBucketLifecycleConfigurationOutput, error)
- func GetObject(ctx context.Context, s3Backend backendstore.S3Client, ...) (*awss3.GetObjectOutput, error)
- func IsAlreadyExists(err error) bool
- func IsBucketNotFound(err error) bool
- func IsNotFound(err error) bool
- func LifecycleConfigurationNotFound(err error) bool
- func ListObjectVersions(ctx context.Context, s3Backend backendstore.S3Client, ...) (*awss3.ListObjectVersionsOutput, error)
- func ListObjectsV2(ctx context.Context, s3Backend backendstore.S3Client, ...) (*awss3.ListObjectsV2Output, error)
- func NewClient(ctx context.Context, data map[string][]byte, ...) (*s3.Client, error)
- func NoSuchBucket(err error) bool
- func PutBucketLifecycleConfiguration(ctx context.Context, s3Backend backendstore.S3Client, b *v1alpha1.Bucket) (*awss3.PutBucketLifecycleConfigurationOutput, error)
- func PutObject(ctx context.Context, s3Backend backendstore.S3Client, ...) error
- func SortFilterTags(rules []types.LifecycleRule)
Constants ¶
View Source
const (
RequestRetries = 5
)
Variables ¶
View Source
var LifecycleNotFoundErrCode = "NoSuchLifecycleConfiguration"
LifecycleNotFoundErrCode is the error code sent by Ceph when the lifecycle config does not exist
View Source
var NoSuchBucketErrCode = "NoSuchBucket"
NoSuchBucketErrCode is the error code sent by Ceph when the bucket does not exist
Functions ¶
func BucketExists ¶ added in v0.0.5
func BucketToCreateBucketInput ¶
func BucketToCreateBucketInput(bucket *v1alpha1.Bucket) *s3.CreateBucketInput
func BucketToPutBucketACLInput ¶ added in v0.0.2
func BucketToPutBucketACLInput(bucket *v1alpha1.Bucket) *s3.PutBucketAclInput
func BucketToPutBucketOwnershipControlsInput ¶ added in v0.0.2
func BucketToPutBucketOwnershipControlsInput(bucket *v1alpha1.Bucket) *s3.PutBucketOwnershipControlsInput
func CreateBucket ¶ added in v0.0.18
func CreateBucket(ctx context.Context, s3Backend backendstore.S3Client, bucket *awss3.CreateBucketInput) (*awss3.CreateBucketOutput, error)
func DeleteBucket ¶ added in v0.0.5
func DeleteBucketLifecycle ¶ added in v0.0.27
func DeleteObject ¶ added in v0.0.28
func DeleteObject(ctx context.Context, s3Backend backendstore.S3Client, input *awss3.DeleteObjectInput) error
func GenerateLifecycleConfigurationInput ¶ added in v0.0.22
func GenerateLifecycleConfigurationInput(name string, config *v1alpha1.BucketLifecycleConfiguration) *awss3.PutBucketLifecycleConfigurationInput
GenerateLifecycleConfiguration creates the PutBucketLifecycleConfigurationInput for the AWS SDK
func GenerateLifecycleRules ¶ added in v0.0.22
func GenerateLifecycleRules(in []v1alpha1.LifecycleRule) []types.LifecycleRule
GenerateLifecycleRules creates the list of LifecycleRules for the AWS SDK
func GetBucketLifecycleConfiguration ¶ added in v0.0.27
func GetBucketLifecycleConfiguration(ctx context.Context, s3Backend backendstore.S3Client, bucketName *string) (*awss3.GetBucketLifecycleConfigurationOutput, error)
func GetObject ¶ added in v0.0.28
func GetObject(ctx context.Context, s3Backend backendstore.S3Client, input *awss3.GetObjectInput) (*awss3.GetObjectOutput, error)
func IsAlreadyExists ¶ added in v0.0.18
IsAlreadyExists helper function to test for ErrCodeBucketAlreadyOwnedByYou error
func IsBucketNotFound ¶ added in v0.0.27
BucketNotFound parses the error and validates if the bucket does not exist
func IsNotFound ¶ added in v0.0.18
IsNotFound helper function to test for NotFound error
func LifecycleConfigurationNotFound ¶ added in v0.0.27
LifecycleConfigurationNotFound is parses the error and validates if the lifecycle configuration does not exist
func ListObjectVersions ¶ added in v0.0.28
func ListObjectVersions(ctx context.Context, s3Backend backendstore.S3Client, input *awss3.ListObjectVersionsInput) (*awss3.ListObjectVersionsOutput, error)
func ListObjectsV2 ¶ added in v0.0.28
func ListObjectsV2(ctx context.Context, s3Backend backendstore.S3Client, input *awss3.ListObjectsV2Input) (*awss3.ListObjectsV2Output, error)
func NewClient ¶
func NewClient(ctx context.Context, data map[string][]byte, pcSpec *apisv1alpha1.ProviderConfigSpec) (*s3.Client, error)
func NoSuchBucket ¶ added in v0.0.19
NoSuchBucket helper function to test for NoSuchBucket error
func PutBucketLifecycleConfiguration ¶ added in v0.0.27
func PutBucketLifecycleConfiguration(ctx context.Context, s3Backend backendstore.S3Client, b *v1alpha1.Bucket) (*awss3.PutBucketLifecycleConfigurationOutput, error)
func PutObject ¶ added in v0.0.28
func PutObject(ctx context.Context, s3Backend backendstore.S3Client, input *awss3.PutObjectInput) error
func SortFilterTags ¶ added in v0.0.22
func SortFilterTags(rules []types.LifecycleRule)
Types ¶
This section is empty.
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.