s3

package

v0.2.0 Latest Latest Go to latest Published: Jun 6, 2022 License: MIT Imports: 14 Imported by: 0

Details

This section is empty.

This section is empty.

func New[T stream.Thing](
	io *session.Session,
	spec *stream.URL,
) stream.Stream[T]

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

func NewCodec[T stream.Thing](rootPath string) Codec[T]

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

func (codec Codec[T]) Encode(entity T) *s3manager.UploadInput

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