stream

Nov 8, 2024

Changes in this version

+ var WithConfig = opts.FMap(optsFromConfig)

+ var WithDefaultS3 = opts.From(optsDefaultS3)

+ var WithRegion = opts.FMap(optsFromRegion)

Nov 3, 2024

Changes in this version

+ type Canceler interface

+ Cancel func() error

Jul 7, 2024

Changes in this version

+ func IsValidDir(path string) bool

+ func IsValidFile(path string) bool

+ func IsValidPath(path string) bool

+ func RequireValidDir(ctx, path string) error

+ func RequireValidFile(ctx, path string) error

+ func RequireValidPath(ctx, path string) error

May 12, 2024

Changes in this version

+ type CopyFS interface

+ Copy func(source, target string) error

+ Wait func(path string, timeout time.Duration) error

+ type CreateFS interface

+ Create func(path string, attr *T) (File, error)

+ type File interface

+ type FileSystem struct

+ func NewFS(bucket string, opts ...Option) (*FileSystem[struct{}], error)

+ func New[T any](bucket string, opts ...Option) (*FileSystem[T], error)

+ func (fsys *FileSystem[T]) Copy(source, target string) error

+ func (fsys *FileSystem[T]) Create(path string, attr *T) (File, error)

+ func (fsys *FileSystem[T]) Glob(pattern string) ([]string, error)

+ func (fsys *FileSystem[T]) Open(path string) (fs.File, error)

+ func (fsys *FileSystem[T]) ReadDir(path string) ([]fs.DirEntry, error)

+ func (fsys *FileSystem[T]) Remove(path string) error

+ func (fsys *FileSystem[T]) Stat(path string) (fs.FileInfo, error)

+ func (fsys *FileSystem[T]) StatSys(stat fs.FileInfo) *T

+ func (fsys *FileSystem[T]) Wait(path string, timeout time.Duration) error

type Option

+ func WithIOTimeout(t time.Duration) Option

+ func WithListingLimit(limit int32) Option

+ func WithPreSignUrlTTL(t time.Duration) Option

+ func WithS3(api S3) Option

+ func WithS3Signer(api S3Signer) Option

+ func WithS3Upload(api S3Upload) Option

+ type Opts struct

+ type PreSignedUrl struct

+ PreSignedUrl string

+ type RemoveFS interface

+ Remove func(path string) error

+ type S3 interface

+ CopyObject func(ctx context.Context, params *s3.CopyObjectInput, optFns ...func(*s3.Options)) (*s3.CopyObjectOutput, error)

+ DeleteObject func(ctx context.Context, params *s3.DeleteObjectInput, optFns ...func(*s3.Options)) (*s3.DeleteObjectOutput, error)

+ GetObject func(ctx context.Context, params *s3.GetObjectInput, optFns ...func(*s3.Options)) (*s3.GetObjectOutput, error)

+ HeadObject func(ctx context.Context, params *s3.HeadObjectInput, optFns ...func(*s3.Options)) (*s3.HeadObjectOutput, error)

+ ListObjectsV2 func(ctx context.Context, params *s3.ListObjectsV2Input, ...) (*s3.ListObjectsV2Output, error)

+ type S3Signer interface

+ PresignGetObject func(ctx context.Context, params *s3.GetObjectInput, ...) (*v4.PresignedHTTPRequest, error)

+ PresignPutObject func(ctx context.Context, params *s3.PutObjectInput, ...) (*v4.PresignedHTTPRequest, error)

+ type S3Upload interface

+ Upload func(ctx context.Context, input *s3.PutObjectInput, opts ...func(*manager.Uploader)) (*manager.UploadOutput, error)

+ type Stat interface

+ Stat func() (fs.FileInfo, error)

+ type SystemMetadata struct

+ CacheControl string

+ ContentEncoding string

+ ContentLanguage string

+ ContentType string

+ ETag string

+ Expires *time.Time

+ LastModified *time.Time

+ StorageClass string

May 4, 2024

Changes in this version

type Stream

+ HashKey func() curie.IRI

+ type Visitor interface

+ Visit func(context.Context, T, func(T) error) error

Jul 13, 2023

Changes in this version

+ func AccessExpiredIn(t time.Duration) interface

+ type Getter interface

+ Get func(context.Context, T, ...interface{ GetterOpt(T) }) (T, io.ReadCloser, error)

+ Has func(context.Context, T, ...interface{ GetterOpt(T) }) (T, error)

+ type Matcher interface

+ Match func(context.Context, T, ...interface{ MatcherOpt(T) }) ([]T, interface{ ... }, error)

+ type Reader interface

+ type Writer interface

+ Put func(context.Context, T, io.Reader, ...interface{ WriterOpt(T) }) error

+ Remove func(context.Context, T, ...interface{ WriterOpt(T) }) error

Apr 2, 2023

Changes in this version

type Config

+ func (*Config) Config()

Dec 1, 2022

Changes in this version

+ func Cursor(c Thing) interface

+ type Limit int32

+ func (Limit) MatchOpt()

Nov 19, 2022

Changes in this version

type Config

+ Service any

type Option

+ func WithService(service any) Option

+ type Streamer interface

Jul 6, 2022

Changes in this version

type StreamWriter

+ Copy func(context.Context, T, T) error

type StreamWriterNoContext

+ Copy func(T, T) error

Jul 4, 2022

Changes in this version

+ func ErrEndOfStream() error

+ func ErrNotFound(err error, key string) error

type NotFound

+ func (e *NotFound) NotFound() bool

+ func (e *NotFound) Unwrap() error

Jun 22, 2022

Changes in this version

+ type Config struct

+ AWS aws.Config

+ Prefixes curie.Prefixes

+ URI *URL

+ func NewConfig(opts ...Option) (*Config, error)

type NotFound

+ Key string

+ type Option func(cfg *Config) error

+ func WithAwsConfig(aws aws.Config) Option

+ func WithPrefixes(prefixes curie.Prefixes) Option

+ func WithURI(uri string) Option

type URL

+ func (uri *URL) String() string

Jun 6, 2022

Changes in this version

+ type EOS struct

+ func (e EOS) Error() string

+ type NotFound struct

+ HashKey string

+ SortKey string

+ func (e NotFound) Error() string

+ type Seq interface

+ FMap func(func(*T, io.ReadCloser) error) error

+ type SeqConfig interface

+ Continue func(Thing) Seq[T]

+ Limit func(int64) Seq[T]

+ Reverse func() Seq[T]

+ type SeqLazy interface

+ Cursor func() Thing

+ Error func() error

+ Head func() (*T, io.ReadCloser, error)

+ Tail func() bool

+ type Stream interface

+ type StreamGetter interface

+ Get func(context.Context, T) (*T, io.ReadCloser, error)

+ Has func(context.Context, T) (bool, error)

+ URL func(context.Context, T, time.Duration) (string, error)

+ type StreamGetterNoContext interface

+ Get func(T) (*T, io.ReadCloser, error)

+ Has func(T) (bool, error)

+ URL func(T, time.Duration) (string, error)

+ type StreamNoContext interface

+ type StreamPattern interface

+ Match func(context.Context, T) Seq[T]

+ type StreamPatternNoContext interface

+ Match func(T) Seq[T]

+ type StreamReader interface

+ type StreamReaderNoContext interface

+ type StreamWriter interface

+ Put func(context.Context, T, io.ReadCloser) error

+ Remove func(context.Context, T) error

+ type StreamWriterNoContext interface

+ Put func(T, io.ReadCloser) error

+ Remove func(T) error

+ type Thing interface

+ HashKey func() string

+ SortKey func() string

+ type URL url.URL

+ func (uri *URL) Query(key, def string) string

+ func (uri *URL) Segments() []string