ipfsutil

Documentation

Overview

Package ipfsutil contains helpers around IPFS (logging, datastore, networking, core API, ...).

Index

• func CreateBuildConfig(opts *CoreAPIConfig) (*ipfs_node.BuildCfg, error)
• func CreateRepo(dstore ipfs_datastore.Batching, opts *CoreAPIConfig) (ipfs_repo.Repo, error)
• func NewConfigurableCoreAPI(ctx context.Context, bcfg *ipfs_node.BuildCfg, opts ...CoreAPIOption) (ipfs_interface.CoreAPI, *ipfs_core.IpfsNode, error)
• func NewCoreAPI(ctx context.Context, cfg *CoreAPIConfig, opts ...CoreAPIOption) (ipfs_interface.CoreAPI, *ipfs_core.IpfsNode, error)
• func NewDatastoreKeystore(ds datastore.Datastore) keystore.Keystore
• func NewNamespacedDatastore(child ds.Datastore, prefix ds.Key) ds.Batching
• func NewTinderRouting(logger *zap.Logger, rdvpeer *peer.AddrInfo, dhtclient bool) (ipfs_p2p.RoutingOption, <-chan *RoutingOut)
• func OptionMDNSDiscovery(ctx context.Context, node *ipfs_core.IpfsNode, api ipfs_interface.CoreAPI) error
• func ParseAndResolveIpfsAddr(ctx context.Context, addr string) (*peer.AddrInfo, error)
• func TestingRDVP(ctx context.Context, t testing.TB, h host.Host) (*rendezvous.RendezvousService, func())
• func TestingRepo(t testing.TB) ipfs_repo.Repo
• type CoreAPIConfig
• type CoreAPIMock
  • func TestingCoreAPI(ctx context.Context, t testing.TB) (CoreAPIMock, func())
  • func TestingCoreAPIUsingMockNet(ctx context.Context, t testing.TB, opts *TestingAPIOpts) (api CoreAPIMock, cleanup func())
• type CoreAPIOption
• type DiscoveryNotifee
  • func (n *DiscoveryNotifee) HandlePeerFound(pi peer.AddrInfo)
• type RoutingOut
• type TestingAPIOpts

Functions

func CreateBuildConfig

func CreateBuildConfig(opts *CoreAPIConfig) (*ipfs_node.BuildCfg, error)

func CreateRepo

func CreateRepo(dstore ipfs_datastore.Batching, opts *CoreAPIConfig) (ipfs_repo.Repo, error)

func NewConfigurableCoreAPI

func NewConfigurableCoreAPI(ctx context.Context, bcfg *ipfs_node.BuildCfg, opts ...CoreAPIOption) (ipfs_interface.CoreAPI, *ipfs_core.IpfsNode, error)

NewConfigurableCoreAPI returns an IPFS CoreAPI from a provided ipfs_node.BuildCfg

func NewCoreAPI

func NewCoreAPI(ctx context.Context, cfg *CoreAPIConfig, opts ...CoreAPIOption) (ipfs_interface.CoreAPI, *ipfs_core.IpfsNode, error)

func NewDatastoreKeystore

func NewDatastoreKeystore(ds datastore.Datastore) keystore.Keystore

func NewNamespacedDatastore

func NewNamespacedDatastore(child ds.Datastore, prefix ds.Key) ds.Batching

func NewTinderRouting

func NewTinderRouting(logger *zap.Logger, rdvpeer *peer.AddrInfo, dhtclient bool) (ipfs_p2p.RoutingOption, <-chan *RoutingOut)

func OptionMDNSDiscovery

func OptionMDNSDiscovery(ctx context.Context, node *ipfs_core.IpfsNode, api ipfs_interface.CoreAPI) error

func ParseAndResolveIpfsAddr

func ParseAndResolveIpfsAddr(ctx context.Context, addr string) (*peer.AddrInfo, error)

parseIpfsAddr is a function that takes in addr string and return ipfsAddrs

func TestingRDVP

func TestingRDVP(ctx context.Context, t testing.TB, h host.Host) (*rendezvous.RendezvousService, func())

func TestingRepo

func TestingRepo(t testing.TB) ipfs_repo.Repo

Types

type CoreAPIConfig

type CoreAPIConfig struct {
	Datastore ipfs_datastore.Batching

	BootstrapAddrs []string
	SwarmAddrs     []string

	ExtraLibp2pOption p2p.Option
	Routing           ipfs_libp2p.RoutingOption
}

type CoreAPIMock

type CoreAPIMock interface {
	ipfs_interface.CoreAPI

	Tinder() tinder.Driver
	MockNetwork() libp2p_mocknet.Mocknet
	MockNode() *ipfs_core.IpfsNode
	Close()
}

CoreAPIMock implements ipfs.CoreAPI and adds some debugging helpers

func TestingCoreAPI

func TestingCoreAPI(ctx context.Context, t testing.TB) (CoreAPIMock, func())

TestingCoreAPI returns a fully initialized mocked Core API. If you want to do some tests involving multiple peers you should use `TestingCoreAPIUsingMockNet` with the same mocknet instead.

func TestingCoreAPIUsingMockNet

func TestingCoreAPIUsingMockNet(ctx context.Context, t testing.TB, opts *TestingAPIOpts) (api CoreAPIMock, cleanup func())

TestingCoreAPIUsingMockNet returns a fully initialized mocked Core API with the given mocknet

type CoreAPIOption

type CoreAPIOption func(context.Context, *ipfs_core.IpfsNode, ipfs_interface.CoreAPI) error

type DiscoveryNotifee

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

func (*DiscoveryNotifee) HandlePeerFound

func (n *DiscoveryNotifee) HandlePeerFound(pi peer.AddrInfo)

type RoutingOut

type RoutingOut struct {
	*dht.IpfsDHT
	tinder.Routing
}

type TestingAPIOpts

type TestingAPIOpts struct {
	Mocknet libp2p_mocknet.Mocknet
	RDVPeer peer.AddrInfo
}