ipfs

Documentation

Index

• Variables
• func DownloadIpfsItem(ctx context.Context, nodeUrl string, cid cid.Cid) (io.ReadCloser, error)
• func DownloadIpfsItemViaGateway(ctx context.Context, gatewayUrl string, cid cid.Cid) (io.ReadCloser, error)
• func GetFileHash(r io.Reader) (string, error)
• func NewDagService() *mapBasedDag
• type AddItemResult
• type Client
• type LinkNodesInput
• type LinkNodesResult
• type SpaceIpfsClient
  • func NewSpaceIpfsClient(cfg config.Config) (*SpaceIpfsClient, error)
  • func (s *SpaceIpfsClient) AddItem(ctx context.Context, item io.Reader) AddItemResult
  • func (s *SpaceIpfsClient) AddItems(ctx context.Context, items []io.Reader) []AddItemResult
  • func (s *SpaceIpfsClient) LinkNodes(ctx context.Context, nodes []LinkNodesInput) (*LinkNodesResult, error)
  • func (s *SpaceIpfsClient) PullItem(ctx context.Context, cid cid.Cid) (io.ReadCloser, error)

Variables

var (
	ErrNotFound = errors.New("not found")
)

Functions

func DownloadIpfsItem

func DownloadIpfsItem(ctx context.Context, nodeUrl string, cid cid.Cid) (io.ReadCloser, error)

func DownloadIpfsItemViaGateway

func DownloadIpfsItemViaGateway(ctx context.Context, gatewayUrl string, cid cid.Cid) (io.ReadCloser, error)

func GetFileHash

func GetFileHash(r io.Reader) (string, error)

func NewDagService

func NewDagService() *mapBasedDag

Types

type AddItemResult

type AddItemResult struct {
	Error    error
	Resolved path.Resolved
}

type Client

type Client interface {
	AddItems(ctx context.Context, items []io.Reader) []AddItemResult
	AddItem(ctx context.Context, item io.Reader) AddItemResult
	// Links each of the nodes in the input under the same parent
	LinkNodes(ctx context.Context, nodes []LinkNodesInput) (*LinkNodesResult, error)
	PullItem(ctx context.Context, cid cid.Cid) (io.ReadCloser, error)
}

type LinkNodesInput

type LinkNodesInput struct {
	// name of link
	Name string
	Path path.Path
}

type LinkNodesResult

type LinkNodesResult struct {
	ParentPath path.Resolved
}

type SpaceIpfsClient

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

func NewSpaceIpfsClient

func NewSpaceIpfsClient(cfg config.Config) (*SpaceIpfsClient, error)

func (*SpaceIpfsClient) AddItem

func (s *SpaceIpfsClient) AddItem(ctx context.Context, item io.Reader) AddItemResult

func (*SpaceIpfsClient) AddItems

func (s *SpaceIpfsClient) AddItems(ctx context.Context, items []io.Reader) []AddItemResult

func (*SpaceIpfsClient) LinkNodes

func (s *SpaceIpfsClient) LinkNodes(ctx context.Context, nodes []LinkNodesInput) (*LinkNodesResult, error)

func (*SpaceIpfsClient) PullItem

func (s *SpaceIpfsClient) PullItem(ctx context.Context, cid cid.Cid) (io.ReadCloser, error)