s3

Documentation

Index

• func New[T dynamo.Thing](cfg *dynamo.Config) dynamo.KeyVal[T]
• type Codec
  • func NewCodec[T dynamo.Thing](prefixes curie.Prefixes) *Codec[T]
  • func (codec Codec[T]) EncodeKey(key T) string
• type S3
• type Schema
  • func NewSchema[T dynamo.Thing]() *Schema[T]
  • func (schema Schema[T]) Merge(a, b T) (c T)

Functions

func New

func New[T dynamo.Thing](cfg *dynamo.Config) dynamo.KeyVal[T]

Types

type Codec

type Codec[T dynamo.Thing] struct {
	// contains filtered or unexported fields
}

Codec is utility to encode/decode objects to s3 representation

func NewCodec

func NewCodec[T dynamo.Thing](prefixes curie.Prefixes) *Codec[T]

func (Codec[T]) EncodeKey

func (codec Codec[T]) EncodeKey(key T) string

type S3

type S3 interface {
	GetObject(context.Context, *s3.GetObjectInput, ...func(*s3.Options)) (*s3.GetObjectOutput, error)
	PutObject(context.Context, *s3.PutObjectInput, ...func(*s3.Options)) (*s3.PutObjectOutput, error)
	DeleteObject(context.Context, *s3.DeleteObjectInput, ...func(*s3.Options)) (*s3.DeleteObjectOutput, error)
	ListObjectsV2(context.Context, *s3.ListObjectsV2Input, ...func(*s3.Options)) (*s3.ListObjectsV2Output, error)
}

S3 declares AWS API used by the library

type Schema

type Schema[T dynamo.Thing] struct{ hseq.Seq[T] }

Schema is utility that merges two struct

func NewSchema

func NewSchema[T dynamo.Thing]() *Schema[T]

func (Schema[T]) Merge

func (schema Schema[T]) Merge(a, b T) (c T)