s3url

package

v0.9.2 Latest Latest Go to latest Published: Apr 2, 2023 License: MIT Imports: 11 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, expire time.Duration) (string, error)

Get

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

Has

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

Match

func (db *Storage[T]) Put(ctx context.Context, entity T, expire time.Duration) (string, error)

Put

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

Remove

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