Documentation ¶
Overview ¶
Package core implements the IpfsNode object and related methods.
Packages underneath core/ provide a (relatively) stable, low-level API to carry out most IPFS-related tasks. For more details on the other interfaces and how core/... fits into the bigger IPFS picture, see:
$ godoc github.com/ipfs/go-ipfs
Index ¶
- Constants
- Variables
- func Bootstrap(n *IpfsNode, cfg BootstrapConfig) (io.Closer, error)
- func Resolve(n *IpfsNode, p path.Path) (*merkledag.Node, error)
- type BootstrapConfig
- type ConfigOption
- type DiscoveryOption
- type HostOption
- type IpfsNode
- type Mounts
- type NodeBuilder
- func (nb *NodeBuilder) Build(ctx context.Context) (*IpfsNode, error)
- func (nb *NodeBuilder) Offline() *NodeBuilder
- func (nb *NodeBuilder) Online() *NodeBuilder
- func (nb *NodeBuilder) SetHost(ho HostOption) *NodeBuilder
- func (nb *NodeBuilder) SetRepo(r repo.Repo) *NodeBuilder
- func (nb *NodeBuilder) SetRouting(ro RoutingOption) *NodeBuilder
- type RoutingOption
Constants ¶
const IpnsValidatorTag = "ipns"
Variables ¶
var DefaultBootstrapConfig = BootstrapConfig{ MinPeerThreshold: 4, Period: 30 * time.Second, ConnectionTimeout: (30 * time.Second) / 3, }
DefaultBootstrapConfig specifies default sane parameters for bootstrapping.
var ErrAlreadyBuilt = errors.New("this builder has already been used")
var ErrNotEnoughBootstrapPeers = errors.New("not enough bootstrap peers to bootstrap")
ErrNotEnoughBootstrapPeers signals that we do not have enough bootstrap peers to bootstrap correctly.
var ErrTooManyLinks = errors.New("exceeded maximum number of links in ipns entry")
Functions ¶
func Bootstrap ¶
func Bootstrap(n *IpfsNode, cfg BootstrapConfig) (io.Closer, error)
Bootstrap kicks off IpfsNode bootstrapping. This function will periodically check the number of open connections and -- if there are too few -- initiate connections to well-known bootstrap peers. It also kicks off subsystem bootstrapping (i.e. routing).
Types ¶
type BootstrapConfig ¶
type BootstrapConfig struct { // MinPeerThreshold governs whether to bootstrap more connections. If the // node has less open connections than this number, it will open connections // to the bootstrap nodes. From there, the routing system should be able // to use the connections to the bootstrap nodes to connect to even more // peers. Routing systems like the IpfsDHT do so in their own Bootstrap // process, which issues random queries to find more peers. MinPeerThreshold int // Period governs the periodic interval at which the node will // attempt to bootstrap. The bootstrap process is not very expensive, so // this threshold can afford to be small (<=30s). Period time.Duration // ConnectionTimeout determines how long to wait for a bootstrap // connection attempt before cancelling it. ConnectionTimeout time.Duration // BootstrapPeers is a function that returns a set of bootstrap peers // for the bootstrap process to use. This makes it possible for clients // to control the peers the process uses at any moment. BootstrapPeers func() []peer.PeerInfo }
BootstrapConfig specifies parameters used in an IpfsNode's network bootstrapping process.
func BootstrapConfigWithPeers ¶
func BootstrapConfigWithPeers(pis []peer.PeerInfo) BootstrapConfig
type ConfigOption ¶
func Offline ¶
func Offline(r repo.Repo) ConfigOption
func Online ¶
func Online(r repo.Repo) ConfigOption
func OnlineWithOptions ¶
func OnlineWithOptions(r repo.Repo, router RoutingOption, ho HostOption) ConfigOption
type HostOption ¶
type HostOption func(ctx context.Context, id peer.ID, ps peer.Peerstore, bwr metrics.Reporter) (p2phost.Host, error)
var DefaultHostOption HostOption = constructPeerHost
type IpfsNode ¶
type IpfsNode struct { // Self Identity peer.ID // the local node's identity Repo repo.Repo // Local node Pinning pin.Pinner // the pinning manager Mounts Mounts // current mount state, if any. PrivateKey ic.PrivKey // the local node's private Key // Services Peerstore peer.Peerstore // storage for other Peer instances Blockstore bstore.Blockstore // the block store (lower level) Blocks *bserv.BlockService // the block service, get/add blocks. DAG merkledag.DAGService // the merkle dag service, get/add objects. Resolver *path.Resolver // the path resolution system Reporter metrics.Reporter Discovery discovery.Service // Online PeerHost p2phost.Host // the network host (server+client) Bootstrapper io.Closer // the periodic bootstrapper Routing routing.IpfsRouting // the routing system. recommend ipfs-dht Exchange exchange.Interface // the block exchange + strategy (bitswap) Namesys namesys.NameSystem // the name system, resolves paths to hashes Diagnostics *diag.Diagnostics // the diagnostics service Reprovider *rp.Reprovider // the value reprovider system IpnsFs *ipnsfs.Filesystem ctxgroup.ContextGroup // contains filtered or unexported fields }
IpfsNode is IPFS Core module. It represents an IPFS instance.
func NewIPFSNode ¶
func NewIPFSNode(parent context.Context, option ConfigOption) (*IpfsNode, error)
func NewMockNode ¶
NewMockNode constructs an IpfsNode for use in tests.
func (*IpfsNode) Bootstrap ¶
func (n *IpfsNode) Bootstrap(cfg BootstrapConfig) error
func (*IpfsNode) HandlePeerFound ¶
func (*IpfsNode) LoadPrivateKey ¶
func (*IpfsNode) OnlineMode ¶
func (*IpfsNode) SetupOfflineRouting ¶
SetupOfflineRouting loads the local nodes private key and uses it to instantiate a routing system in offline mode. This is primarily used for offline ipns modifications.
type Mounts ¶
Mounts defines what the node's mount state is. This should perhaps be moved to the daemon or mount. It's here because it needs to be accessible across daemon requests.
type NodeBuilder ¶
type NodeBuilder struct {
// contains filtered or unexported fields
}
NodeBuilder is an object used to generate an IpfsNode
func NewNodeBuilder ¶
func NewNodeBuilder() *NodeBuilder
func (*NodeBuilder) Offline ¶
func (nb *NodeBuilder) Offline() *NodeBuilder
func (*NodeBuilder) Online ¶
func (nb *NodeBuilder) Online() *NodeBuilder
func (*NodeBuilder) SetHost ¶
func (nb *NodeBuilder) SetHost(ho HostOption) *NodeBuilder
func (*NodeBuilder) SetRepo ¶
func (nb *NodeBuilder) SetRepo(r repo.Repo) *NodeBuilder
func (*NodeBuilder) SetRouting ¶
func (nb *NodeBuilder) SetRouting(ro RoutingOption) *NodeBuilder
type RoutingOption ¶
type RoutingOption func(context.Context, p2phost.Host, ds.ThreadSafeDatastore) (routing.IpfsRouting, error)
var DHTOption RoutingOption = constructDHTRouting
Directories ¶
Path | Synopsis |
---|---|
Package commands implements the IPFS command interface
|
Package commands implements the IPFS command interface |
internal/incfusever
Package incfusever is only here to prevent go src tools (like godep) from thinking fuseversion is not a required package.
|
Package incfusever is only here to prevent go src tools (like godep) from thinking fuseversion is not a required package. |
Package corehttp provides utilities for the webui, gateways, and other high-level HTTP interfaces to IPFS.
|
Package corehttp provides utilities for the webui, gateways, and other high-level HTTP interfaces to IPFS. |
Package corerepo provides pinning and garbage collection for local IPFS block services.
|
Package corerepo provides pinning and garbage collection for local IPFS block services. |