ipfs

Documentation

Index

• Variables
• func DownloadIpfsItem(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, 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)