blobstore

Documentation

Index

• type Blobstore
  • func New(endpoint, region, bucket, accessKey, secretKey string, ...) (*Blobstore, error)
  • func (bs *Blobstore) Delete(node *node.Node) error
  • func (bs *Blobstore) Download(node *node.Node) (io.ReadCloser, error)
  • func (bs *Blobstore) List() ([]*node.Node, error)
  • func (bs *Blobstore) Path(node *node.Node) string
  • func (bs *Blobstore) Upload(node *node.Node, source string) error
• type Options

Types

type Blobstore

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

Blobstore provides an interface to an s3 compatible blobstore

func New

func New(endpoint, region, bucket, accessKey, secretKey string, defaultPutOptions Options) (*Blobstore, error)

New returns a new Blobstore

func (*Blobstore) Delete

func (bs *Blobstore) Delete(node *node.Node) error

Delete deletes a blob from the blobstore

func (*Blobstore) Download

func (bs *Blobstore) Download(node *node.Node) (io.ReadCloser, error)

Download retrieves a blob from the blobstore for reading

func (*Blobstore) List

func (bs *Blobstore) List() ([]*node.Node, error)

List lists all blobs in the Blobstore

func (*Blobstore) Path

func (bs *Blobstore) Path(node *node.Node) string

func (*Blobstore) Upload

func (bs *Blobstore) Upload(node *node.Node, source string) error

Upload stores some data in the blobstore under the given key

type Options

type Options struct {
	DisableContentSha256  bool
	DisableMultipart      bool
	SendContentMd5        bool
	ConcurrentStreamParts bool
	NumThreads            uint
	PartSize              uint64
}