corerepo

Documentation

Overview

Package corerepo provides pinning and garbage collection for local IPFS block services.

IPFS nodes will keep local copies of any object that have either been added or requested locally. Not all of these objects are worth preserving forever though, so the node adminstrator can pin objects they want to keep and unpin objects that they don't care about.

Garbage collection sweeps iterate through the local block store removing objects that aren't pinned, which frees storage space for new objects.

Index

• Variables
• func BestEffortRoots(filesRoot *mfs.Root) ([]*cid.Cid, error)
• func ConditionalGC(ctx context.Context, node *core.IpfsNode, offset uint64) error
• func GarbageCollect(n *core.IpfsNode, ctx context.Context) error
• func GarbageCollectAsync(n *core.IpfsNode, ctx context.Context) (<-chan *KeyRemoved, error)
• func PeriodicGC(ctx context.Context, node *core.IpfsNode) error
• func Pin(n *core.IpfsNode, ctx context.Context, paths []string, recursive bool) ([]*cid.Cid, error)
• func Unpin(n *core.IpfsNode, ctx context.Context, paths []string, recursive bool) ([]*cid.Cid, error)
• type GC
  • func NewGC(n *core.IpfsNode) (*GC, error)
• type KeyRemoved
• type Stat
  • func RepoStat(n *core.IpfsNode, ctx context.Context) (*Stat, error)

Variables

var ErrMaxStorageExceeded = errors.New("Maximum storage limit exceeded. Maybe unpin some files?")

Functions

func BestEffortRoots

func BestEffortRoots(filesRoot *mfs.Root) ([]*cid.Cid, error)

func ConditionalGC

func ConditionalGC(ctx context.Context, node *core.IpfsNode, offset uint64) error

func GarbageCollect

func GarbageCollect(n *core.IpfsNode, ctx context.Context) error

func GarbageCollectAsync

func GarbageCollectAsync(n *core.IpfsNode, ctx context.Context) (<-chan *KeyRemoved, error)

func PeriodicGC

func PeriodicGC(ctx context.Context, node *core.IpfsNode) error

func Pin

func Pin(n *core.IpfsNode, ctx context.Context, paths []string, recursive bool) ([]*cid.Cid, error)

func Unpin

func Unpin(n *core.IpfsNode, ctx context.Context, paths []string, recursive bool) ([]*cid.Cid, error)

Types

type GC

type GC struct {
	Node       *core.IpfsNode
	Repo       repo.Repo
	StorageMax uint64
	StorageGC  uint64
	SlackGB    uint64
	Storage    uint64
}

func NewGC

func NewGC(n *core.IpfsNode) (*GC, error)

type KeyRemoved

type KeyRemoved struct {
	Key *cid.Cid
}

type Stat

type Stat struct {
	NumObjects uint64
	RepoSize   uint64 // size in bytes
	RepoPath   string
	Version    string
}

func RepoStat

func RepoStat(n *core.IpfsNode, ctx context.Context) (*Stat, error)