testutils

Documentation

Index

• func DeleteBucket(ctx context.Context, svc DeleteBucketAPI, bucketName string) error
• func SkipIfUnitTest(t *testing.T)
• type APIClient
• type Bucket
  • func (b *Bucket) Name() string
• type BucketPool
  • func NewBucketPool(input *s3.CreateBucketInput, svc APIClient, size int) *BucketPool
  • func (pool *BucketPool) Cleanup(ctx context.Context)
  • func (pool *BucketPool) Get(ctx context.Context) (*Bucket, error)
  • func (pool *BucketPool) Put(bucket *Bucket)
• type DeleteBucketAPI

Functions

func DeleteBucket

func DeleteBucket(ctx context.Context, svc DeleteBucketAPI, bucketName string) error

DeleteBucket deletes a S3 bucket.

func SkipIfUnitTest

func SkipIfUnitTest(t *testing.T)

SkipIfUnitTest skips join tests.

Types

type APIClient

type APIClient interface {
	interfaces.BucketCreator
	interfaces.BucketHeader
	interfaces.ObjectListerV2
	interfaces.ObjectDeleter
	interfaces.BucketDeleter
}

type Bucket

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

Bucket is an S3 bucket. It is used for integration tests.

func (*Bucket) Name

func (b *Bucket) Name() string

type BucketPool

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

BucketPool is a pool of buckets.

func NewBucketPool

func NewBucketPool(input *s3.CreateBucketInput, svc APIClient, size int) *BucketPool

func (*BucketPool) Cleanup

func (pool *BucketPool) Cleanup(ctx context.Context)

func (*BucketPool) Get

func (pool *BucketPool) Get(ctx context.Context) (*Bucket, error)

func (*BucketPool) Put

func (pool *BucketPool) Put(bucket *Bucket)

type DeleteBucketAPI

type DeleteBucketAPI interface {
	interfaces.BucketDeleter
	interfaces.ObjectListerV2
	interfaces.ObjectDeleter
}