aws

Documentation

Index

• func NewDynamoClient(workspace, region string) (*dynamodb.Client, error)
• func NewS3Client(workspace, region string) (*s3.Client, error)
• type AwsLock
  • func NewAwsLock(client *dynamodb.Client, workspace, table string) *AwsLock
  • func (l *AwsLock) Lock() error
  • func (l *AwsLock) Unlock() error
• type AwsTransport
  • func NewAwsTransport(client *s3.Client, workspace, bucket string) *AwsTransport
  • func (t *AwsTransport) Reader(key string) (io.ReadCloser, error)
  • func (t *AwsTransport) Writer(key string) (io.WriteCloser, error)
• type AwsUploader
  • func (u *AwsUploader) Close() error
  • func (u *AwsUploader) Write(b []byte) (int, error)

Functions

func NewDynamoClient

func NewDynamoClient(workspace, region string) (*dynamodb.Client, error)

func NewS3Client

func NewS3Client(workspace, region string) (*s3.Client, error)

Types

type AwsLock

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

func NewAwsLock

func NewAwsLock(client *dynamodb.Client, workspace, table string) *AwsLock

func (*AwsLock) Lock

func (l *AwsLock) Lock() error

func (*AwsLock) Unlock

func (l *AwsLock) Unlock() error

type AwsTransport

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

func NewAwsTransport

func NewAwsTransport(client *s3.Client, workspace, bucket string) *AwsTransport

func (*AwsTransport) Reader

func (t *AwsTransport) Reader(key string) (io.ReadCloser, error)

func (*AwsTransport) Writer

func (t *AwsTransport) Writer(key string) (io.WriteCloser, error)

type AwsUploader

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

func (*AwsUploader) Close

func (u *AwsUploader) Close() error

func (*AwsUploader) Write

func (u *AwsUploader) Write(b []byte) (int, error)