s3url

Documentation

Index

• type Option
  • func WithBucket(bucket string) Option
  • func WithPrefixes(prefixes curie.Prefixes) Option
  • func WithS3(service *s3.Client) Option
• type Options
• type Storage
  • func New[T stream.Thing](opts ...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, entity T, opts ...interface{ GetterOpt(T) }) (string, error)
  • func (db *Storage[T]) Has(ctx context.Context, entity T, opts ...interface{ GetterOpt(T) }) (T, error)
  • func (db *Storage[T]) Match(ctx context.Context, key T, opts ...interface{ MatcherOpt(T) }) ([]string, interface{ ... }, error)
  • func (db *Storage[T]) Put(ctx context.Context, entity T, opts ...interface{ WriterOpt(T) }) (string, error)
  • func (db *Storage[T]) Remove(ctx context.Context, entity T, opts ...interface{ WriterOpt(T) }) error
  • func (db *Storage[T]) Wait(ctx context.Context, key T, timeout time.Duration) error

Types

type Option

type Option func(*Options)

Option type to configure the connection

func WithBucket

func WithBucket(bucket string) Option

WithBucket defined bucket for I/O

func WithPrefixes

func WithPrefixes(prefixes curie.Prefixes) Option

WithPrefixes defines prefixes for CURIEs

func WithS3

func WithS3(service *s3.Client) Option

Configure AWS Service for broker instance

type Options

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

Generic Config Options

type Storage

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

func New

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

func (*Storage[T]) Copy

func (db *Storage[T]) Copy(ctx context.Context, source T, target T) error

func (*Storage[T]) Get

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

Get

func (*Storage[T]) Has

func (db *Storage[T]) Has(ctx context.Context, entity T, opts ...interface{ GetterOpt(T) }) (T, error)

Has

func (*Storage[T]) Match

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

Match

func (*Storage[T]) Put

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

Put

func (*Storage[T]) Remove

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

Remove

func (*Storage[T]) Wait

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