ipfs

Documentation

Index

• Constants
• Variables
• type DataType
• type Proxy
  • func NewIpfsProxy(cfg *config.IpfsConfig, bus eventbus.Bus) (Proxy, error)
  • func NewMemoryIpfsProxy() Proxy

Constants

const (
	CidLength        = 36
	ZeroPeersTimeout = 2 * time.Minute
)

Variables

var (
	EmptyCid  cid.Cid
	MinCid    [CidLength]byte
	MaxCid    [CidLength]byte
	TooBigErr = errors.New("ipfs data is too big")
)

Types

type DataType

type DataType = uint32

const (
	Block      DataType = 1
	Flip       DataType = 2
	Profile    DataType = 3
	TxReceipt  DataType = 4
	CustomData DataType = 5
)

type Proxy

type Proxy interface {
	Add(data []byte, pin bool) (cid.Cid, error)
	Get(key []byte, dataType DataType) ([]byte, error)
	LoadTo(key []byte, to io.Writer, ctx context.Context, onLoading func(size, loaded int64)) error
	Pin(key []byte) error
	Unpin(key []byte) error
	Cid(data []byte) (cid.Cid, error)
	Port() int
	PeerId() string
	AddFile(absPath string, data io.ReadCloser, fi os.FileInfo) (cid.Cid, error)
	Host() core2.Host
	ShouldPin(dataType DataType) bool
	GetWithSizeLimit(key []byte, dataType DataType, size int64) ([]byte, error)
	PubSub() *pubsub.PubSub
	GC() (ctx context.Context, cancel context.CancelFunc)
}

func NewIpfsProxy

func NewIpfsProxy(cfg *config.IpfsConfig, bus eventbus.Bus) (Proxy, error)

func NewMemoryIpfsProxy

func NewMemoryIpfsProxy() Proxy