ipfs

type IIpfs interface {
	ID() (*ipfsapi.IdOutput, error)
	PubSubPublish(topic string, data string) error
	PubSubSubscribe(topic string) (IPubSubSubscription, error)
	Get(hash string, outdir string) error
	AddDir(dir string) (string, error)
	Publish(node string, value string) error
	Add(r io.Reader) (string, error)
	P2PListen(ctx context.Context, protocol, maddr string) (*P2PListener, error)
	P2PCloseListener(ctx context.Context, protocol string, closeAll bool) error
	P2PStreamDial(ctx context.Context, peerID, protocol, listenerMaddr string) (*P2PStream, error)
	P2PCloseStream(ctx context.Context, handlerID string, closeAll bool) error
}

type IPubSubSubscription interface {
	Cancel() error
	Next() (*ipfsapi.Message, error)
}

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

type P2PListener struct {
	Protocol string
	Address  string
}

type P2PStream struct {
	Protocol string
	Address  string
}

type PubSubSubscription ipfsapi.PubSubSubscription