codec

Documentation

Index

• type Codec
  • func New[T stream.Thing](prefixes curie.Prefixes) Codec[T]
  • func (codec Codec[T]) DecodeGetObject(obj *s3.GetObjectOutput) T
  • func (codec Codec[T]) DecodeHasObject(obj *s3.HeadObjectOutput) T
  • func (codec Codec[T]) Encode(entity T) *s3.PutObjectInput
  • func (codec Codec[T]) EncodeKey(key stream.Thing) string

Types

type Codec

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

func New

func New[T stream.Thing](prefixes curie.Prefixes) Codec[T]

func (Codec[T]) DecodeGetObject

func (codec Codec[T]) DecodeGetObject(obj *s3.GetObjectOutput) T

func (Codec[T]) DecodeHasObject

func (codec Codec[T]) DecodeHasObject(obj *s3.HeadObjectOutput) T

func (Codec[T]) Encode

func (codec Codec[T]) Encode(entity T) *s3.PutObjectInput

func (Codec[T]) EncodeKey

func (codec Codec[T]) EncodeKey(key stream.Thing) string