s3

package

v0.12.0 Latest Latest Go to latest Published: May 4, 2024 License: MIT Imports: 10 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Option func(*Options)

Option type to configure the connection

func WithBucket(bucket string) Option

WithBucket defined bucket for I/O

func WithPrefixes(prefixes curie.Prefixes) Option

WithPrefixes defines prefixes for CURIEs

func WithS3(service *s3.Client) Option

Configure AWS Service for broker instance

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

Generic Config Options

type Storage[T stream.Stream] struct {
	*s3ts.Store[T]
	// contains filtered or unexported fields
}

func New[T stream.Stream](opts ...Option) (*Storage[T], error)

New client instance

func (db *Storage[T]) Get(ctx context.Context, key T, opts ...interface{ GetterOpt(T) }) (T, io.ReadCloser, error)

Get stream and its metadata from store

func (db *Storage[T]) Put(ctx context.Context, entity T, val io.Reader, opts ...interface{ WriterOpt(T) }) error

Put stream into store