repo

Documentation

Index

• Constants
• func NewAferoBlob(root string) (*aferoBlob, error)
• func NewInMemBlob() (aferoBlob, error)
• type MinioAdapter
  • func NewMinioBlob(addr, key, secret string) (*MinioAdapter, error)
  • func (s *MinioAdapter) CreateBucket(ctx context.Context, bucketName string) (any, error)
  • func (s *MinioAdapter) Delete(ctx context.Context, bucketName, key string) error
  • func (s *MinioAdapter) Get(ctx context.Context, bucketName, filename string) (*blob.ObjectInfo, error)
  • func (s *MinioAdapter) GetShareUrl(bucket, key string) blob.ShareFunc
  • func (s *MinioAdapter) Info(ctx context.Context, bucketName, fileName string) (*blob.ObjectInfo, error)
  • func (s *MinioAdapter) ObjectIterator(ctx context.Context, bucketName string, limit int, lastFilename string) blob.Iterator
  • func (s *MinioAdapter) Put(ctx context.Context, bucketName, key string, file io.Reader, size int64, ...) (*blob.ObjectInfo, error)
• type Result

Constants

const DefaultEndpoint = "127.0.0.1:9000"

Functions

func NewAferoBlob

func NewAferoBlob(root string) (*aferoBlob, error)

func NewInMemBlob

func NewInMemBlob() (aferoBlob, error)

Types

type MinioAdapter

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

represent blob storage

func NewMinioBlob

func NewMinioBlob(addr, key, secret string) (*MinioAdapter, error)

func (*MinioAdapter) CreateBucket

func (s *MinioAdapter) CreateBucket(ctx context.Context, bucketName string) (any, error)

func (*MinioAdapter) Delete

func (s *MinioAdapter) Delete(ctx context.Context, bucketName, key string) error

func (*MinioAdapter) Get

func (s *MinioAdapter) Get(ctx context.Context, bucketName, filename string) (*blob.ObjectInfo, error)

func (*MinioAdapter) GetShareUrl

func (s *MinioAdapter) GetShareUrl(bucket, key string) blob.ShareFunc

func (*MinioAdapter) Info

func (s *MinioAdapter) Info(ctx context.Context, bucketName, fileName string) (*blob.ObjectInfo, error)

func (*MinioAdapter) ObjectIterator

func (s *MinioAdapter) ObjectIterator(ctx context.Context, bucketName string, limit int, lastFilename string) blob.Iterator

func (*MinioAdapter) Put

func (s *MinioAdapter) Put(ctx context.Context, bucketName, key string, file io.Reader, size int64, contentType string) (*blob.ObjectInfo, error)

type Result

type Result struct {
	Sum       string
	Timestamp time.Time
}