s3_service

Documentation

Index

• Constants
• func New(provider core.AwsProvider) (storage.StorageService, error)
• func NewWithClient(provider core.AwsProvider, client s3iface.S3API, ...) (storage.StorageService, error)
• type BucketSelector
• type S3StorageService
  • func (s *S3StorageService) Delete(bucket string, key string) error
  • func (s *S3StorageService) PreSignUrl(bucket string, key string, operation storage.Operation, expiry uint32) (string, error)
  • func (s *S3StorageService) Read(bucket string, key string) ([]byte, error)
  • func (s *S3StorageService) Write(bucket string, key string, object []byte) error
• type S3StorageServiceOption
  • func WithSelector(selector BucketSelector) S3StorageServiceOption

Constants

const (
	// ErrCodeNoSuchTagSet - AWS API neglects to include a constant for this error code.
	ErrCodeNoSuchTagSet = "NoSuchTagSet"
	ErrCodeAccessDenied = "AccessDenied"
)

Functions

func New

func New(provider core.AwsProvider) (storage.StorageService, error)

New creates a new default S3 storage plugin

func NewWithClient

func NewWithClient(provider core.AwsProvider, client s3iface.S3API, opts ...S3StorageServiceOption) (storage.StorageService, error)

NewWithClient creates a new S3 Storage plugin and injects the given client

Types

type BucketSelector

type BucketSelector = func(nitricName string) (*string, error)

type S3StorageService

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

S3StorageService - Is the concrete implementation of AWS S3 for the Nitric Storage Plugin

func (*S3StorageService) Delete

func (s *S3StorageService) Delete(bucket string, key string) error

Delete - Deletes an item from a bucket

func (*S3StorageService) PreSignUrl

func (s *S3StorageService) PreSignUrl(bucket string, key string, operation storage.Operation, expiry uint32) (string, error)

PreSignUrl - generates a signed URL which can be used to perform direct operations on a file useful for large file uploads/downloads so they can bypass application code and work directly with S3

func (*S3StorageService) Read

func (s *S3StorageService) Read(bucket string, key string) ([]byte, error)

Read - Retrieves an item from a bucket

func (*S3StorageService) Write

func (s *S3StorageService) Write(bucket string, key string, object []byte) error

Write - Writes an item to a bucket

type S3StorageServiceOption

type S3StorageServiceOption interface {
	Apply(*S3StorageService)
}

func WithSelector

func WithSelector(selector BucketSelector) S3StorageServiceOption