s3

package

v0.8.0 Latest Latest Go to latest Published: Dec 1, 2022 License: MIT Imports: 13 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func (obj Object[T]) CopyTo(ctx context.Context, target T) (Object[T], error)

func (obj Object[T]) Wait(ctx context.Context, timeout time.Duration) error

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

func New[T stream.Thing](connector string, opts ...stream.Option) (*Storage[T], error)

func (db *Storage[T]) Get(ctx context.Context, key T) (T, io.ReadCloser, error)

Get item from storage

func (db *Storage[T]) Has(ctx context.Context, key T) (T, error)

Has

func (db *Storage[T]) Match(ctx context.Context, key T, opts ...interface{ MatchOpt() }) ([]T, error)

Match

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

Put

func (db *Storage[T]) Remove(ctx context.Context, key T) error

Remove

func (db *Storage[T]) With(entity T) Object[T]

With