blobs

Mar 14, 2023

Changes in this version

+ type IdGenerator interface

+ NextId func() Id

type Option

+ func WithIdGenerator(idGenerator IdGenerator) Option

+ type SystemTimeMock struct

+ Time time.Time

+ func (c *SystemTimeMock) Now() time.Time

+ type TestIdgenerator struct

+ func (idGen *TestIdgenerator) NextId() Id

+ type UlidIdGenerator struct

+ func (_ UlidIdGenerator) NextId() Id

Mar 11, 2023

Changes in this version

+ type Reader struct

+ func (br *Reader) Read(buf []byte) (int, error)

+ type Store struct

+ func NewStore(db fdb.Database, ns string, opts ...Option) (*Store, error)

+ func (store *Store) Blob(id Id) (*Blob, error)

+ func (store *Store) CommitUpload(tr fdb.Transaction, uploadToken UploadToken) (Id, error)

+ func (store *Store) Create(ctx context.Context, r io.Reader) (*Blob, error)

+ func (store *Store) DeleteRemovedBlobsBefore(date time.Time) ([]Id, error)

+ func (store *Store) DeleteUploadsStartedBefore(date time.Time) ([]Id, error)

+ func (store *Store) RemoveBlob(id Id) error

+ func (store *Store) Upload(ctx context.Context, r io.Reader) (UploadToken, error)

Mar 10, 2023

Changes in this version

type BlobStore

+ DeleteRemovedBlobsBefore func(date time.Time) ([]Id, error)

+ RemoveBlob func(id Id) error

Mar 10, 2023

Changes in this version

type BlobStore

+ DeleteUploadsStartedBefore func(date time.Time) ([]Id, error)

type Option

+ func WithSystemTime(systemTime SystemTime) Option

+ type SystemTime interface

+ Now func() time.Time

Mar 8, 2023

Changes in this version

+ type Blob interface

+ Content func(cxt context.Context) ([]byte, error)

+ CreatedAt func() (time.Time, error)

+ Id func() Id

+ Len func() (int, error)

+ Reader func() (BlobReader, error)

type BlobStore

+ Blob func(id Id) (Blob, error)

Mar 2, 2023

Changes in this version

type BlobStore

+ CommitUpload func(tr fdb.Transaction, uploadToken UploadToken) Id

+ CreatedAt func(id Id) (time.Time, error)

+ Upload func(ctx context.Context, r io.Reader) (UploadToken, error)

+ type UploadToken interface

Feb 16, 2023

Changes in this version

+ type Id string

+ func (id Id) FDBKey() fdb.Key

Feb 15, 2023

Changes in this version

+ var BlobNotFoundError = errors.New("blob not found")

+ type BlobReader interface

+ type BlobStore interface

+ BlobReader func(id string) (BlobReader, error)

+ Create func(reader io.Reader) (string, error)

+ Len func(id string) (uint64, error)

+ Read func(id string) ([]byte, error)

+ func NewFdbStore(db fdb.Database, ns string, opts ...Option) BlobStore

+ type Option func(br *fdbBlobStore)

+ func WithChunkSize(chunkSize uint) Option

+ func WithChunksPerTransaction(chunksPerTransaction uint) Option