ipfs

Apr 28, 2020

Changes in this version

+ func EncodeCID(b []byte) (*cid.Cid, error)

+ func EncodeMultihash(b []byte) (*mh.Multihash, error)

+ func ExtractIDFromPointer(pi ps.PeerInfo) (string, error)

+ type PubKey interface

Nov 7, 2019

Changes in this version

+ func DeleteCachedIPNSRecord(store ds.Datastore, id peer.ID) error

+ func GetCachedIPNSRecord(store ds.Datastore, id peer.ID) (*ipnspb.IpnsEntry, error)

+ func GetCachedPubkey(store ds.Datastore, peerID string) ([]byte, error)

+ func PutCachedPubkey(store ds.Datastore, peerID string, pubkey []byte) error

May 1, 2019

Changes in this version

+ const IPFSProtocolAppMainnetOne

+ const IPFSProtocolAppTestnetOne

+ const IPFSProtocolBitswapMainnetNoVers

+ const IPFSProtocolBitswapMainnetOne

+ const IPFSProtocolBitswapMainnetOneDotOne

+ const IPFSProtocolBitswapTestnetNoVers

+ const IPFSProtocolBitswapTestnetOne

+ const IPFSProtocolBitswapTestnetOneDotOne

+ const IPFSProtocolDHTMainnetLegacy

+ const IPFSProtocolDHTTestnetLegacy

+ const IPFSProtocolKademliaMainnetOne

+ const IPFSProtocolKademliaTestnetOne

+ var ErrCachingRouterIncorrectRoutingType = errors.New("Incorrect routing type")

+ var ErrNotStarted = errors.New("API router not started")

+ func InstallDatabasePlugins()

+ func PrepareIPFSConfig(r repo.Repo, routerAPIEndpoint string, testEnable, regtestEnable bool) *ipfscore.BuildCfg

+ func UpdateIPFSGlobalProtocolVars(testnetEnable bool)

+ type APIRouter struct

+ func NewAPIRouter(uri string, validator record.Validator) APIRouter

+ func (r *APIRouter) Start(proxyDialer proxy.Dialer)

+ func (r APIRouter) Bootstrap(_ context.Context) error

+ func (r APIRouter) FindPeer(_ context.Context, id peer.ID) (pstore.PeerInfo, error)

+ func (r APIRouter) FindProvidersAsync(_ context.Context, _ cid.Cid, _ int) <-chan pstore.PeerInfo

+ func (r APIRouter) GetValue(ctx context.Context, key string, opts ...ropts.Option) ([]byte, error)

+ func (r APIRouter) GetValues(ctx context.Context, key string, opts ...ropts.Option) ([]byte, error)

+ func (r APIRouter) Provide(_ context.Context, _ cid.Cid, _ bool) error

+ func (r APIRouter) PutValue(ctx context.Context, key string, value []byte, opts ...ropts.Option) error

+ func (r APIRouter) SearchValue(ctx context.Context, key string, opts ...ropts.Option) (<-chan []byte, error)

+ type CachingRouter struct

+ func NewCachingRouter(dht *dht.IpfsDHT, apiRouter *APIRouter) *CachingRouter

+ func (r *CachingRouter) APIRouter() *APIRouter

+ func (r *CachingRouter) DHT() (*dht.IpfsDHT, error)

+ func (r *CachingRouter) GetPublicKey(ctx context.Context, p peer.ID) (ci.PubKey, error)

+ func (r *CachingRouter) GetValue(ctx context.Context, key string, opts ...ropts.Option) ([]byte, error)

+ func (r *CachingRouter) PutValue(ctx context.Context, key string, value []byte, opts ...ropts.Option) error

+ func (r *CachingRouter) SearchValue(ctx context.Context, key string, opts ...ropts.Option) (<-chan []byte, error)

Mar 19, 2019

Changes in this version

+ const MagicPointerID

Sep 5, 2018

Changes in this version

+ const GlobalBlockTopic

+ const GlobalCIDTopic

+ const GlobalIPNSTopic

+ const MessageTopicPrefix

+ type Pubsub struct

+ Publisher *PubsubPublisher

+ Subscriber *PubsubSubscriber

+ type PubsubPublisher struct

+ func NewPubsubPublisher(ctx context.Context, host p2phost.Host, cr routing.ContentRouting, ...) *PubsubPublisher

+ func (p *PubsubPublisher) Publish(ctx context.Context, topic string, data []byte) error

+ type PubsubSubscriber struct

+ func NewPubsubSubscriber(ctx context.Context, host p2phost.Host, cr routing.ContentRouting, ...) *PubsubSubscriber

+ func (r *PubsubSubscriber) Cancel(name string) bool

+ func (r *PubsubSubscriber) GetSubscriptions() []string

+ func (r *PubsubSubscriber) Subscribe(ctx context.Context, topic string) (chan []byte, error)

May 9, 2018

Changes in this version

+ func PublishAltRoot(ctx commands.Context, nd *core.IpfsNode, altRoot string, value path.Path, ...) error

+ func PutRecordToRouting(ctx context.Context, ipnskey string, k ci.PrivKey, value path.Path, ...) error

+ func ResolveAltRoot(ctx commands.Context, p peer.ID, altRoot string, timeout time.Duration) (string, error)

Mar 9, 2018

Changes in this version

+ func RemoveAll(ctx commands.Context, peerID string) error

Oct 13, 2017

Changes in this version

+ func GetPointersFromPeer(node *core.IpfsNode, ctx context.Context, p peer.ID, key *cid.Cid) ([]*ps.PeerInfo, error)

+ func PutPointerToPeer(node *core.IpfsNode, ctx context.Context, peer peer.ID, pointer Pointer) error

Sep 26, 2017

Changes in this version

+ func FetchGraph(dag merkledag.DAGService, id *cid.Cid) ([]cid.Cid, error)

type Pointer

+ func NewPointer(mhKey multihash.Multihash, prefixLen int, addr ma.Multiaddr, entropy []byte) (Pointer, error)

Jul 7, 2017

Changes in this version

+ func CreatePointerKey(mh multihash.Multihash, prefixLen int) multihash.Multihash

Apr 21, 2017

Changes in this version

+ func GetHashOfFile(ctx commands.Context, fpath string) (string, error)

Mar 24, 2017

Changes in this version

type Pointer

+ CancelID *peer.ID

Jan 25, 2017

Changes in this version

+ func GetHash(ctx commands.Context, fpath string) (string, error)

type Pointer

+ Cid *cid.Cid

Dec 14, 2016

Changes in this version

+ func BlockstoreHas(ctx commands.Context, hash string) (bool, error)

Aug 27, 2016

Changes in this version

+ const CatTimeout

+ const ResolveTimeout

+ func NewRequestWithTimeout(ctx cmds.Context, args []string, timeout time.Duration) (cmds.Request, *cmds.Command, error)

+ func Resolve(ctx commands.Context, hash string) (string, error)

+ func ResolveThenCat(ctx commands.Context, ipnsPath path.Path) ([]byte, error)

Aug 17, 2016

Changes in this version

+ const MAGIC

+ var Root = &cmds.Command

+ func AddDirectory(ctx commands.Context, fpath string) (string, error)

+ func AddFile(ctx commands.Context, fpath string) (string, error)

+ func Cat(ctx commands.Context, hash string) ([]byte, error)

+ func ConnectedPeers(ctx commands.Context) ([]string, error)

+ func FindPointers(dht *routing.IpfsDHT, ctx context.Context, mhKey multihash.Multihash, ...) ([]ps.PeerInfo, error)

+ func FindPointersAsync(dht *routing.IpfsDHT, ctx context.Context, mhKey multihash.Multihash, ...) <-chan ps.PeerInfo

+ func IdentityFromKey(privkey []byte) (config.Identity, error)

+ func IdentityKeyFromSeed(seed []byte, bits int) ([]byte, error)

+ func MockCmdsCtx() (commands.Context, error)

+ func MockHostOption(mn mocknet.Mocknet) core.HostOption

+ func NewMockNode() (*core.IpfsNode, error)

+ func NewRequest(ctx cmds.Context, args []string) (cmds.Request, *cmds.Command, error)

+ func Publish(ctx commands.Context, hash string) (string, error)

+ func Query(ctx commands.Context, peerID string) ([]peer.ID, error)

+ func RePublishPointer(node *core.IpfsNode, ctx context.Context, pointer Pointer) error

+ func UnPinDir(ctx commands.Context, rootHash string) error

+ type DeterministicReader struct

+ Counter int

+ Seed []byte

+ func (d *DeterministicReader) Read(p []byte) (n int, err error)

+ type Pointer struct

+ Key key.Key

+ Purpose Purpose

+ Timestamp time.Time

+ Value ps.PeerInfo

+ func PublishPointer(node *core.IpfsNode, ctx context.Context, mhKey multihash.Multihash, ...) (Pointer, error)

+ type Purpose int

+ const CHANNEL

+ const MESSAGE

+ const MODERATOR

+ const TAG