Versions in this module Expand all Collapse all v0 v0.1.1 Jun 19, 2020 Changes in this version + const DefaultBufferSize + const DefaultFormatParser + const DefaultIenc + const DefaultMhType + var DefaultBootstrappers = []string + var ErrNoLinks = fmt.Errorf("no links found in IPFS DAG node") + var ErrOffline = fmt.Errorf("the IPFS node is offline") + var ErrRepoAlreadyInitialised = fmt.Errorf("specified IPFS repo is already initialised") + type Client struct + func NewIPFSclient(ctx context.Context) (*Client, error) + func (client *Client) AddFile(ctx context.Context, filePath string, pinning bool) (string, error) + func (client *Client) AddLink(ctx context.Context, baseCID, childCID, linkLabel string) (string, error) + func (client *Client) Connect(ctx context.Context, peers []string, logger chan interface{}) + func (client *Client) DagGet(ctx context.Context, queryCID string) (interface{}, error) + func (client *Client) DagPut(ctx context.Context, data []byte, pinning bool) (string, error) + func (client *Client) EndSession() error + func (client *Client) GetFile(ctx context.Context, cidStr, outputPath string) error + func (client *Client) GetNodeData(ctx context.Context, nodeCID string) (io.Reader, error) + func (client *Client) GetNodeLinks(ctx context.Context, nodeCID string) ([]*ipld.Link, error) + func (client *Client) GetPSEchan() chan error + func (client *Client) GetPSMchan() chan icore.PubSubMessage + func (client *Client) GetPeers(ctx context.Context) ([]string, error) + func (client *Client) GetPublicIPv4Addr() (string, error) + func (client *Client) NewDagNode(ctx context.Context) (string, error) + func (client *Client) Online() bool + func (client *Client) PrintNodeID() string + func (client *Client) RmLink(ctx context.Context, baseCID, linkLabel string) (string, error) + func (client *Client) SendMessage(ctx context.Context, topic string, message []byte) error + func (client *Client) Subscribe(ctx context.Context, topic string) error + func (client *Client) Unpin(ctx context.Context, cidStr string) error + func (client *Client) Unsubscribe() error