blob

package

v0.0.0-...-3adb936 Latest Latest Go to latest Published: Aug 29, 2023 License: MIT, Unlicense Imports: 20 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Blob struct {
	Key    string
	Data   []byte
	Source string
}

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

func NewBucket(
	ctx context.Context,
	bucketURL string,
	options ...BucketOption,
) (*Bucket, error)

func (bu *Bucket) Close()

func (bu *Bucket) Exists(ctx context.Context, key string) (ok bool, err error)

func (bu *Bucket) GetBlob(ctx context.Context, key string) (b *Blob, err error)

func (bu *Bucket) List(options ...ListOption) *ListIterator

func (bu *Bucket) SetBlob(ctx context.Context, key string, data []byte, opts ...WriteOption) error

func (bu *Bucket) WithPrefix(prefix string) *Bucket

WithPrefix returns a new bucket with the given prefix.

type BucketOption interface {
	// contains filtered or unexported methods
}

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

func (it *ListIterator) Err() error

func (it *ListIterator) Key() string

func (it *ListIterator) Next(ctx context.Context) bool

func (it *ListIterator) Value(ctx context.Context) (*Blob, error)

type ListOption interface {
	// contains filtered or unexported methods
}

type NotFoundError struct {
	Key string
}

NotFoundError is returned when a key is not found in the bucket.

func (e *NotFoundError) Error() string

type OptBucketCacheDir struct {
	CacheDir string
}

type OptBucketNoCache struct {
	NoCache bool
}

type OptListPrefix struct {
	Prefix string
}

type OptWriteCacheTTL struct {
	TTL time.Duration
}

type WriteOption interface {
	// contains filtered or unexported methods
}