s3storage

Documentation

Index

• type MockS3
  • func NewMockS3(t *testing.T) *MockS3
  • func (s *MockS3) Start(t *testing.T)
  • func (s *MockS3) Stop()
• type S3Storage
  • func NewS3Storage(region aws.Region, auth aws.Auth, bucketName string, prefix string, ...) (*S3Storage, error)
  • func NewStorageWithMockS3(s *MockS3) (*S3Storage, error)
  • func (s *S3Storage) Delete(path string) error
  • func (s *S3Storage) Get(path string) (io.ReadCloser, error)
  • func (s *S3Storage) List(prefix string, maxSize int) ([]string, error)
  • func (s *S3Storage) Lock(path string) error
  • func (s *S3Storage) Put(path string, data []byte) error
  • func (s *S3Storage) PutReader(path string, reader io.Reader) error
  • func (s *S3Storage) Unlock(path string) error

Types

type MockS3

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

MockS3 mocks S3Storage

func NewMockS3

func NewMockS3(t *testing.T) *MockS3

NewMockS3 constructs a MockS3

func (*MockS3) Start

func (s *MockS3) Start(t *testing.T)

Start starts server used for MockS3

func (*MockS3) Stop

func (s *MockS3) Stop()

Stop stops server used for MockS3

type S3Storage

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

S3Storage implements the strata.Storage interface using S3 as its storage backing

func NewS3Storage

func NewS3Storage(region aws.Region, auth aws.Auth, bucketName string, prefix string, bucketACL s3.ACL) (*S3Storage, error)

NewS3Storage initializes the S3Storage with required AWS arguments

func NewStorageWithMockS3

func NewStorageWithMockS3(s *MockS3) (*S3Storage, error)

NewStorageWithMockS3 constructs an S3Storage that uses MockS3

func (*S3Storage) Delete

func (s *S3Storage) Delete(path string) error

Delete removes the object at the given S3 path

func (*S3Storage) Get

func (s *S3Storage) Get(path string) (io.ReadCloser, error)

Get returns a reader to the specified S3 path. The reader is a wrapper around a ChecksummingReader. This protects against network corruption.

func (*S3Storage) List

func (s *S3Storage) List(prefix string, maxSize int) ([]string, error)

List returns a list of objects (up to maxSize) with the given prefix from S3

func (*S3Storage) Lock

func (s *S3Storage) Lock(path string) error

Lock is not implemented

func (*S3Storage) Put

func (s *S3Storage) Put(path string, data []byte) error

Put places the byte slice at the given path in S3. Put also sends a checksum to protect against network corruption.

func (*S3Storage) PutReader

func (s *S3Storage) PutReader(path string, reader io.Reader) error

PutReader consumes the given reader and stores it at the specified path in S3. A checksum is used to protect against network corruption.

func (*S3Storage) Unlock

func (s *S3Storage) Unlock(path string) error

Unlock is not implemented