s3

package

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

Details

This section is empty.

This section is empty.

This section is empty.

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]) Copy(ctx context.Context, source T, target 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) (T, error)

Remove

func (db *Storage[T]) Wait(ctx context.Context, key T, timeout time.Duration) error