node

Documentation

Index

• Constants
• Variables
• func BaseBlockstoreCtor(cacheOpts blockstore.CacheOpts, nilRepo bool, hashOnRead bool) ...
• func BlockService(lc fx.Lifecycle, bs blockstore.Blockstore, rem exchange.Interface) blockservice.BlockService
• func DMS3(ctx context.Context, bcfg *BuildCfg) fx.Option
• func Dag(bs blockservice.BlockService) format.DAGService
• func Datastore(repo repo.Repo) datastore.Datastore
• func Dms3NsRepublisher(repubPeriod time.Duration, recordLifetime time.Duration) func(lcProcess, namesys.NameSystem, repo.Repo, crypto.PrivKey) error
• func Files(mctx helpers.MetricsCtx, lc fx.Lifecycle, repo repo.Repo, ...) (*mfs.Root, error)
• func FilestoreBlockstoreCtor(repo repo.Repo, bb BaseBlocks) (gclocker blockstore.GCLocker, gcbs blockstore.GCBlockstore, ...)
• func GcBlockstoreCtor(bb BaseBlocks) (gclocker blockstore.GCLocker, gcbs blockstore.GCBlockstore, ...)
• func Graphsync(lc fx.Lifecycle, mctx helpers.MetricsCtx, host p2p.Host, ...) graphsync.GraphExchange
• func Identity(cfg *config.Config) fx.Option
• func Namesys(cacheSize int) func(rt routing.Routing, repo repo.Repo) (namesys.NameSystem, error)
• func Networked(bcfg *BuildCfg, cfg *config.Config) fx.Option
• func Offline(cfg *config.Config) fx.Option
• func OfflineProviders(useStrategicProviding bool, reprovideStrategy string, reprovideInterval string) fx.Option
• func Online(bcfg *BuildCfg, cfg *config.Config) fx.Option
• func OnlineExchange(provide bool) interface{}
• func OnlineProviders(useStrategicProviding bool, reprovideStrategy string, reprovideInterval string) fx.Option
• func P2p(bcfg *BuildCfg, cfg *config.Config) fx.Option
• func PeerID(id peer.ID) func() peer.ID
• func PeerWith(peers ...peer.AddrInfo) fx.Option
• func Peering(lc fx.Lifecycle, host host.Host) *peering.PeeringService
• func Pinning(bstore blockstore.Blockstore, ds format.DAGService, repo repo.Repo) (pin.Pinner, error)
• func PrivateKey(sk crypto.PrivKey) func(id peer.ID) (crypto.PrivKey, error)
• func ProviderQueue(mctx helpers.MetricsCtx, lc fx.Lifecycle, repo repo.Repo) (*q.Queue, error)
• func RecordValidator(ps peerstore.Peerstore) record.Validator
• func RepoConfig(repo repo.Repo) (*config.Config, error)
• func SimpleProvider(mctx helpers.MetricsCtx, lc fx.Lifecycle, queue *q.Queue, rt routing.Routing) provider.Provider
• func SimpleProviderSys(isOnline bool) interface{}
• func SimpleProviders(reprovideStrategy string, reprovideInterval string) fx.Option
• func SimpleReprovider(reproviderInterval time.Duration) interface{}
• func Storage(bcfg *BuildCfg, cfg *config.Config) fx.Option
• type BaseBlocks
• type BuildCfg

Constants

const DefaultDms3NsCacheSize = 128

Variables

var BaseP2p = fx.Options(
	fx.Provide(dms3p2p.UserAgent),
	fx.Provide(dms3p2p.PNet),
	fx.Provide(dms3p2p.ConnectionManager),
	fx.Provide(dms3p2p.Host),

	fx.Provide(dms3p2p.DiscoveryHandler),

	fx.Invoke(dms3p2p.PNetChecker),
)

var Core = fx.Options(
	fx.Provide(BlockService),
	fx.Provide(Dag),
	fx.Provide(resolver.NewBasicResolver),
	fx.Provide(Pinning),
	fx.Provide(Files),
)

Core groups basic DMS3 services

var DMS3NS = fx.Options(
	fx.Provide(RecordValidator),
)

DMS3NS groups namesys related units

Functions

func BaseBlockstoreCtor

func BaseBlockstoreCtor(cacheOpts blockstore.CacheOpts, nilRepo bool, hashOnRead bool) func(mctx helpers.MetricsCtx, repo repo.Repo, lc fx.Lifecycle) (bs BaseBlocks, err error)

BaseBlockstoreCtor creates cached blockstore backed by the provided datastore

func BlockService

func BlockService(lc fx.Lifecycle, bs blockstore.Blockstore, rem exchange.Interface) blockservice.BlockService

BlockService creates new blockservice which provides an interface to fetch content-addressable blocks

func DMS3

func DMS3(ctx context.Context, bcfg *BuildCfg) fx.Option

DMS3 builds a group of fx Options based on the passed BuildCfg

func Dag

func Dag(bs blockservice.BlockService) format.DAGService

Dag creates new DAGService

func Datastore

func Datastore(repo repo.Repo) datastore.Datastore

Datastore provides the datastore

func Dms3NsRepublisher

func Dms3NsRepublisher(repubPeriod time.Duration, recordLifetime time.Duration) func(lcProcess, namesys.NameSystem, repo.Repo, crypto.PrivKey) error

Dms3NsRepublisher runs new DMS3NS republisher service

func Files

func Files(mctx helpers.MetricsCtx, lc fx.Lifecycle, repo repo.Repo, dag format.DAGService) (*mfs.Root, error)

Files loads persisted MFS root

func FilestoreBlockstoreCtor

func FilestoreBlockstoreCtor(repo repo.Repo, bb BaseBlocks) (gclocker blockstore.GCLocker, gcbs blockstore.GCBlockstore, bs blockstore.Blockstore, fstore *filestore.Filestore)

GcBlockstoreCtor wraps GcBlockstore and adds Filestore support

func GcBlockstoreCtor

func GcBlockstoreCtor(bb BaseBlocks) (gclocker blockstore.GCLocker, gcbs blockstore.GCBlockstore, bs blockstore.Blockstore)

GcBlockstoreCtor wraps the base blockstore with GC and Filestore layers

func Graphsync

func Graphsync(lc fx.Lifecycle, mctx helpers.MetricsCtx, host p2p.Host, bs blockstore.GCBlockstore) graphsync.GraphExchange

Graphsync constructs a graphsync

func Identity

func Identity(cfg *config.Config) fx.Option

Identity groups units providing cryptographic identity

func Namesys

func Namesys(cacheSize int) func(rt routing.Routing, repo repo.Repo) (namesys.NameSystem, error)

Namesys creates new name system

func Networked

func Networked(bcfg *BuildCfg, cfg *config.Config) fx.Option

func Offline

func Offline(cfg *config.Config) fx.Option

Offline groups offline alternatives to Online units

func OfflineProviders

func OfflineProviders(useStrategicProviding bool, reprovideStrategy string, reprovideInterval string) fx.Option

OfflineProviders groups units managing provider routing records offline

func Online

func Online(bcfg *BuildCfg, cfg *config.Config) fx.Option

Online groups online-only units

func OnlineExchange

func OnlineExchange(provide bool) interface{}

OnlineExchange creates new P2p backed block exchange (BitSwap)

func OnlineProviders

func OnlineProviders(useStrategicProviding bool, reprovideStrategy string, reprovideInterval string) fx.Option

OnlineProviders groups units managing provider routing records online

func P2p

func P2p(bcfg *BuildCfg, cfg *config.Config) fx.Option

func PeerID

func PeerID(id peer.ID) func() peer.ID

func PeerWith

func PeerWith(peers ...peer.AddrInfo) fx.Option

PeerWith configures the peering service to peer with the specified peers.

func Peering

func Peering(lc fx.Lifecycle, host host.Host) *peering.PeeringService

Peering constructs the peering service and hooks it into fx's lifetime management system.

func Pinning

func Pinning(bstore blockstore.Blockstore, ds format.DAGService, repo repo.Repo) (pin.Pinner, error)

Pinning creates new pinner which tells GC which blocks should be kept

func PrivateKey

func PrivateKey(sk crypto.PrivKey) func(id peer.ID) (crypto.PrivKey, error)

PrivateKey loads the private key from config

func ProviderQueue

func ProviderQueue(mctx helpers.MetricsCtx, lc fx.Lifecycle, repo repo.Repo) (*q.Queue, error)

ProviderQueue creates new datastore backed provider queue

func RecordValidator

func RecordValidator(ps peerstore.Peerstore) record.Validator

RecordValidator provides namesys compatible routing record validator

func RepoConfig

func RepoConfig(repo repo.Repo) (*config.Config, error)

RepoConfig loads configuration from the repo

func SimpleProvider

func SimpleProvider(mctx helpers.MetricsCtx, lc fx.Lifecycle, queue *q.Queue, rt routing.Routing) provider.Provider

SimpleProvider creates new record provider

func SimpleProviderSys

func SimpleProviderSys(isOnline bool) interface{}

SimpleProviderSys creates new provider system

func SimpleProviders

func SimpleProviders(reprovideStrategy string, reprovideInterval string) fx.Option

SimpleProviders creates the simple provider/reprovider dependencies

func SimpleReprovider

func SimpleReprovider(reproviderInterval time.Duration) interface{}

SimpleReprovider creates new reprovider

func Storage

func Storage(bcfg *BuildCfg, cfg *config.Config) fx.Option

Storage groups units which setup datastore based persistence and blockstore layers

Types

type BaseBlocks

type BaseBlocks blockstore.Blockstore

BaseBlocks is the lower level blockstore without GC or Filestore layers

type BuildCfg

type BuildCfg struct {
	// If online is set, the node will have networking enabled
	Online bool

	// ExtraOpts is a map of extra options used to configure the dms3 nodes creation
	ExtraOpts map[string]bool

	// If permanent then node should run more expensive processes
	// that will improve performance in long run
	Permanent bool

	// DisableEncryptedConnections disables connection encryption *entirely*.
	// DO NOT SET THIS UNLESS YOU'RE TESTING.
	DisableEncryptedConnections bool

	// If NilRepo is set, a Repo backed by a nil datastore will be constructed
	NilRepo bool

	Routing dms3p2p.RoutingOption
	Host    dms3p2p.HostOption
	Repo    repo.Repo
}