repo

Documentation

Index

• Variables
• type Mock
  • func (m *Mock) Close() error
  • func (m *Mock) Config() (*config.Config, error)
  • func (m *Mock) Datastore() ds.ThreadSafeDatastore
  • func (m *Mock) GetConfigKey(key string) (interface{}, error)
  • func (m *Mock) GetStorageUsage() (uint64, error)
  • func (m *Mock) SetAPIAddr(addr string) error
  • func (m *Mock) SetConfig(updated *config.Config) error
  • func (m *Mock) SetConfigKey(key string, value interface{}) error
• type OnlyOne
  • func (o *OnlyOne) Open(key interface{}, open func() (Repo, error)) (Repo, error)
• type Repo

Variables

var (
	ErrApiNotRunning = errors.New("api not running")
)

Types

type Mock

type Mock struct {
	C config.Config
	D ds.ThreadSafeDatastore
}

Mock is not thread-safe

func (*Mock) Close

func (m *Mock) Close() error

func (*Mock) Config

func (m *Mock) Config() (*config.Config, error)

func (*Mock) Datastore

func (m *Mock) Datastore() ds.ThreadSafeDatastore

func (*Mock) GetConfigKey

func (m *Mock) GetConfigKey(key string) (interface{}, error)

func (*Mock) GetStorageUsage

func (m *Mock) GetStorageUsage() (uint64, error)

func (*Mock) SetAPIAddr

func (m *Mock) SetAPIAddr(addr string) error

func (*Mock) SetConfig

func (m *Mock) SetConfig(updated *config.Config) error

func (*Mock) SetConfigKey

func (m *Mock) SetConfigKey(key string, value interface{}) error

type OnlyOne

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

OnlyOne tracks open Repos by arbitrary key and returns the already open one.

func (*OnlyOne) Open

func (o *OnlyOne) Open(key interface{}, open func() (Repo, error)) (Repo, error)

Open a Repo identified by key. If Repo is not already open, the open function is called, and the result is remember for further use.

Key must be comparable, or Open will panic. Make sure to pick keys that are unique across different concrete Repo implementations, e.g. by creating a local type:

type repoKey string
r, err := o.Open(repoKey(path), open)

Call Repo.Close when done.

type Repo

type Repo interface {
	Config() (*config.Config, error)
	SetConfig(*config.Config) error

	SetConfigKey(key string, value interface{}) error
	GetConfigKey(key string) (interface{}, error)

	Datastore() datastore.ThreadSafeDatastore
	GetStorageUsage() (uint64, error)

	// SetAPIAddr sets the API address in the repo.
	SetAPIAddr(addr string) error

	io.Closer
}