store

Documentation

Index

• Variables
• type FileStore
  • func NewFile(base string) (*FileStore, error)
  • func (s *FileStore) Close() error
  • func (s *FileStore) StreamFrom(path string, w io.Writer) (err error)
  • func (s *FileStore) StreamTo(path string, source io.Reader) (err error)
• type MongoDBStore
  • func NewMongoDB(url, user, pass, db, name string) (store *MongoDBStore, err error)
  • func (s MongoDBStore) Close() error
  • func (s MongoDBStore) StreamFrom(path string, w io.Writer) (err error)
  • func (s MongoDBStore) StreamTo(path string, source io.Reader) (err error)

Variables

var ErrNoMongoHost = errors.New("parameter 'url' is empty")

ErrNoMongoHost is returned if no[[host]:port] combination for MongoDB was provided,

Types

type FileStore

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

FileStore represents a filesystem based file Repository.

func NewFile

func NewFile(base string) (*FileStore, error)

NewFile creates a new filesystem based file Repository.

func (*FileStore) Close

func (s *FileStore) Close() error

Close satisfies the Repository interface, but is a noop for a filesystem based repo.

func (*FileStore) StreamFrom

func (s *FileStore) StreamFrom(path string, w io.Writer) (err error)

StreamFrom statisfies the Retriever interface.

func (*FileStore) StreamTo

func (s *FileStore) StreamTo(path string, source io.Reader) (err error)

StreamTo satisfies the Storer interface.

type MongoDBStore

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

MongoDBStore represents a GridFS based file Repository.

func NewMongoDB

func NewMongoDB(url, user, pass, db, name string) (store *MongoDBStore, err error)

NewMongoDB creates a GridFS based repository.

func (MongoDBStore) Close

func (s MongoDBStore) Close() error

Close satisfies the Repository interface.

func (MongoDBStore) StreamFrom

func (s MongoDBStore) StreamFrom(path string, w io.Writer) (err error)

StreamFrom statisfies the Retriever interface.

func (MongoDBStore) StreamTo

func (s MongoDBStore) StreamTo(path string, source io.Reader) (err error)

StreamTo satisfies the Storer interface.