repo

Documentation

Index

• Constants
• Variables
• func BadgerBlockstoreOptions(domain BlockstoreDomain, path string, readonly bool) (badgerbs.Options, error)
• type BlockstoreDomain
• type FsRepo
  • func NewFS(path string) (*FsRepo, error)
  • func (fsr *FsRepo) APIEndpoint() (multiaddr.Multiaddr, error)
  • func (fsr *FsRepo) APIToken() ([]byte, error)
  • func (fsr *FsRepo) Exists() (bool, error)
  • func (fsr *FsRepo) Init(t RepoType) error
  • func (fsr *FsRepo) Lock(repoType RepoType) (LockedRepo, error)
  • func (fsr *FsRepo) LockRO(repoType RepoType) (LockedRepo, error)
  • func (fsr *FsRepo) SetConfigPath(cfgPath string)
• type LockedRepo
• type MemRepo
  • func NewMemory(opts *MemRepoOptions) *MemRepo
  • func (mem *MemRepo) APIEndpoint() (multiaddr.Multiaddr, error)
  • func (mem *MemRepo) APIToken() ([]byte, error)
  • func (mem *MemRepo) Cleanup()
  • func (mem *MemRepo) Lock(t RepoType) (LockedRepo, error)
• type MemRepoOptions
• type Repo
• type RepoType
  • func NewRepoTypeFromString(t string) RepoType

Constants

const (
	// UniversalBlockstore represents the blockstore domain for all data.
	// Right now, this includes chain objects (tipsets, blocks, messages), as
	// well as state. In the future, they may get segregated into different
	// domains.
	UniversalBlockstore = BlockstoreDomain("universal")
	HotBlockstore       = BlockstoreDomain("hot")
)

const KTrashPrefix = "trash-"

Variables

var (
	ErrNoAPIEndpoint     = errors.New("API not running (no endpoint)")
	ErrNoAPIToken        = errors.New("API token not set")
	ErrRepoAlreadyLocked = errors.New("repo is already locked (process is already running)")
	ErrClosedRepo        = errors.New("repo is no longer open")

	// ErrInvalidBlockstoreDomain is returned by LockedRepo#Blockstore() when
	// an unrecognized domain is requested.
	ErrInvalidBlockstoreDomain = errors.New("invalid blockstore domain")
)

var ErrRepoExists = xerrors.New("repo exists")

var FullNode fullNode

var StorageMiner storageMiner

var Wallet wallet

var Worker worker

Functions

func BadgerBlockstoreOptions

func BadgerBlockstoreOptions(domain BlockstoreDomain, path string, readonly bool) (badgerbs.Options, error)

BadgerBlockstoreOptions returns the badger options to apply for the provided domain.

Types

type BlockstoreDomain

type BlockstoreDomain string

BlockstoreDomain represents the domain of a blockstore.

type FsRepo

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

FsRepo is struct for repo, use NewFS to create

func NewFS

func NewFS(path string) (*FsRepo, error)

NewFS creates a repo instance based on a path on file system

func (*FsRepo) APIEndpoint

func (fsr *FsRepo) APIEndpoint() (multiaddr.Multiaddr, error)

APIEndpoint returns endpoint of API in this repo

func (*FsRepo) APIToken

func (fsr *FsRepo) APIToken() ([]byte, error)

func (*FsRepo) Exists

func (fsr *FsRepo) Exists() (bool, error)

func (*FsRepo) Init

func (fsr *FsRepo) Init(t RepoType) error

func (*FsRepo) Lock

func (fsr *FsRepo) Lock(repoType RepoType) (LockedRepo, error)

Lock acquires exclusive lock on this repo

func (*FsRepo) LockRO

func (fsr *FsRepo) LockRO(repoType RepoType) (LockedRepo, error)

LockRO is like Lock, except datastores will work in read-only mode

func (*FsRepo) SetConfigPath

func (fsr *FsRepo) SetConfigPath(cfgPath string)

type LockedRepo

type LockedRepo interface {
	// Close closes repo and removes lock.
	Close() error

	// returns the type of this repo
	RepoType() RepoType

	// Returns datastore defined in this repo.
	// The supplied context must only be used to initialize the datastore.
	// The implementation should not retain the context for usage throughout
	// the lifecycle.
	Datastore(ctx context.Context, namespace string) (datastore.Batching, error)

	// Blockstore returns an IPLD blockstore for the requested domain.
	// The supplied context must only be used to initialize the blockstore.
	// The implementation should not retain the context for usage throughout
	// the lifecycle.
	Blockstore(ctx context.Context, domain BlockstoreDomain) (blockstore.Blockstore, error)

	// SplitstorePath returns the path for the SplitStore
	SplitstorePath() (string, error)

	// SqlitePath returns the path for the Sqlite database
	SqlitePath() (string, error)

	// Returns config in this repo
	Config() (interface{}, error)
	SetConfig(func(interface{})) error

	GetStorage() (storiface.StorageConfig, error)
	SetStorage(func(*storiface.StorageConfig)) error
	Stat(path string) (fsutil.FsStat, error)
	DiskUsage(path string) (int64, error)

	// SetAPIEndpoint sets the endpoint of the current API
	// so it can be read by API clients
	SetAPIEndpoint(multiaddr.Multiaddr) error

	// SetAPIToken sets JWT API Token for CLI
	SetAPIToken([]byte) error

	// KeyStore returns store of private keys for Filecoin transactions
	KeyStore() (types.KeyStore, error)

	// Path returns absolute path of the repo
	Path() string

	// Readonly returns true if the repo is readonly
	Readonly() bool
}

type MemRepo

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

func NewMemory

func NewMemory(opts *MemRepoOptions) *MemRepo

NewMemory creates new memory based repo with provided options. opts can be nil, it will be replaced with defaults. Any field in opts can be nil, they will be replaced by defaults.

func (*MemRepo) APIEndpoint

func (mem *MemRepo) APIEndpoint() (multiaddr.Multiaddr, error)

func (*MemRepo) APIToken

func (mem *MemRepo) APIToken() ([]byte, error)

func (*MemRepo) Cleanup

func (mem *MemRepo) Cleanup()

func (*MemRepo) Lock

func (mem *MemRepo) Lock(t RepoType) (LockedRepo, error)

type MemRepoOptions

type MemRepoOptions struct {
	Ds       datastore.Datastore
	KeyStore map[string]types.KeyInfo
}

MemRepoOptions contains options for memory repo

type Repo

type Repo interface {
	// APIEndpoint returns multiaddress for communication with Lotus API
	APIEndpoint() (multiaddr.Multiaddr, error)

	// APIToken returns JWT API Token for use in operations that require auth
	APIToken() ([]byte, error)

	// Lock locks the repo for exclusive use.
	Lock(RepoType) (LockedRepo, error)
}

type RepoType

type RepoType interface {
	Type() string
	Config() interface{}

	// APIFlags returns flags passed on the command line with the listen address
	// of the API server (only used by the tests), in the order of precedence they
	// should be applied for the requested kind of node.
	APIFlags() []string

	RepoFlags() []string

	// APIInfoEnvVars returns the environment variables to use in order of precedence
	// to determine the API endpoint of the specified node type.
	//
	// It returns the current variables and deprecated ones separately, so that
	// the user can log a warning when deprecated ones are found to be in use.
	APIInfoEnvVars() (string, []string, []string)
}

func NewRepoTypeFromString

func NewRepoTypeFromString(t string) RepoType