fsrepo

Documentation

Overview

package fsrepo

TODO explain the package roadmap...

.ipfs/
├── client/
|   ├── client.lock          <------ protects client/ + signals its own pid
│   ├── ipfs-client.cpuprof
│   └── ipfs-client.memprof
├── config
├── daemon/
│   ├── daemon.lock          <------ protects daemon/ + signals its own address
│   ├── ipfs-daemon.cpuprof
│   └── ipfs-daemon.memprof
├── datastore/
├── repo.lock                <------ protects datastore/ and config
└── version

Index

• Variables
• func APIAddr(repoPath string) (ma.Multiaddr, error)
• func BestKnownPath() (string, error)
• func ConfigAt(repoPath string) (*config.Config, error)
• func Init(repoPath string, conf *config.Config) error
• func IsInitialized(path string) bool
• func LockedByOtherProcess(repoPath string) (bool, error)
• func Open(repoPath string) (repo.Repo, error)
• type FSRepo
  • func (r *FSRepo) Close() error
  • func (r *FSRepo) Config() (*config.Config, error)
  • func (r *FSRepo) Datastore() repo.Datastore
  • func (r *FSRepo) FileManager() *filestore.FileManager
  • func (r *FSRepo) GetConfigKey(key string) (interface{}, error)
  • func (r *FSRepo) GetStorageUsage() (uint64, error)
  • func (r *FSRepo) Keystore() keystore.Keystore
  • func (r *FSRepo) Path() string
  • func (r *FSRepo) SetAPIAddr(addr ma.Multiaddr) error
  • func (r *FSRepo) SetConfig(updated *config.Config) error
  • func (r *FSRepo) SetConfigKey(key string, value interface{}) error
  • func (r *FSRepo) SwarmKey() ([]byte, error)
• type NoRepoError
  • func (err NoRepoError) Error() string

Variables

var (
	ErrNoVersion     = errors.New("no version file found, please run 0-to-1 migration tool.\n" + migrationInstructions)
	ErrOldRepo       = errors.New("ipfs repo found in old '~/.go-ipfs' location, please run migration tool.\n" + migrationInstructions)
	ErrNeedMigration = errors.New("ipfs repo needs migration.")
)

var RepoVersion = 5

version number that we are currently expecting to see

Functions

func APIAddr

func APIAddr(repoPath string) (ma.Multiaddr, error)

APIAddr returns the registered API addr, according to the api file in the fsrepo. This is a concurrent operation, meaning that any process may read this file. modifying this file, therefore, should use "mv" to replace the whole file and avoid interleaved read/writes.

func BestKnownPath

func BestKnownPath() (string, error)

BestKnownPath returns the best known fsrepo path. If the ENV override is present, this function returns that value. Otherwise, it returns the default repo path.

func ConfigAt

func ConfigAt(repoPath string) (*config.Config, error)

ConfigAt returns an error if the FSRepo at the given path is not initialized. This function allows callers to read the config file even when another process is running and holding the lock.

func Init

func Init(repoPath string, conf *config.Config) error

Init initializes a new FSRepo at the given path with the provided config. TODO add support for custom datastores.

func IsInitialized

func IsInitialized(path string) bool

IsInitialized returns true if the repo is initialized at provided |path|.

func LockedByOtherProcess

func LockedByOtherProcess(repoPath string) (bool, error)

LockedByOtherProcess returns true if the FSRepo is locked by another process. If true, then the repo cannot be opened by this process.

func Open

func Open(repoPath string) (repo.Repo, error)

Open the FSRepo at path. Returns an error if the repo is not initialized.

Types

type FSRepo

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

FSRepo represents an IPFS FileSystem Repo. It is safe for use by multiple callers.

func (*FSRepo) Close

func (r *FSRepo) Close() error

Close closes the FSRepo, releasing held resources.

func (*FSRepo) Config

func (r *FSRepo) Config() (*config.Config, error)

Result when not Open is undefined. The method may panic if it pleases.

func (*FSRepo) Datastore

func (r *FSRepo) Datastore() repo.Datastore

Datastore returns a repo-owned datastore. If FSRepo is Closed, return value is undefined.

func (*FSRepo) FileManager

func (r *FSRepo) FileManager() *filestore.FileManager

func (*FSRepo) GetConfigKey

func (r *FSRepo) GetConfigKey(key string) (interface{}, error)

GetConfigKey retrieves only the value of a particular key.

func (*FSRepo) GetStorageUsage

func (r *FSRepo) GetStorageUsage() (uint64, error)

GetStorageUsage computes the storage space taken by the repo in bytes

func (*FSRepo) Keystore

func (r *FSRepo) Keystore() keystore.Keystore

func (*FSRepo) Path

func (r *FSRepo) Path() string

func (*FSRepo) SetAPIAddr

func (r *FSRepo) SetAPIAddr(addr ma.Multiaddr) error

SetAPIAddr writes the API Addr to the /api file.

func (*FSRepo) SetConfig

func (r *FSRepo) SetConfig(updated *config.Config) error

SetConfig updates the FSRepo's config.

func (*FSRepo) SetConfigKey

func (r *FSRepo) SetConfigKey(key string, value interface{}) error

SetConfigKey writes the value of a particular key.

func (*FSRepo) SwarmKey

func (r *FSRepo) SwarmKey() ([]byte, error)

type NoRepoError

type NoRepoError struct {
	Path string
}

func (NoRepoError) Error

func (err NoRepoError) Error() string