ipfs

package

v0.0.0-...-e1789b5 Latest Latest Go to latest Published: Oct 1, 2023 License: GPL-3.0 Imports: 36 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/allisterb/flubber

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func GenerateIPFSNodeKeyPair() ([]byte, []byte, error)
func GenerateIPNSKeyPair() ([]byte, []byte, error)
func GetIPFSNodeIdentity(pubb []byte) peer.ID
func GetIPFSNodeIdentityFromPublicKeyName(key string) (peer.ID, error)
func GetIPNSPublicKeyName(pubb []byte) (string, error)
func GetIPNSRecordFromW3S(ctx context.Context, authToken string, name string) (cid.Cid, error)
func GetSubscriptionPeers(ctx context.Context, ipfscore IPFSCore, topic string) ([]peer.ID, error)
func GetSubscriptionTopics(ctx context.Context, ipfscore IPFSCore) ([]string, error)
func PinIPFSBlockToW3S(ctx context.Context, ipfs iface.CoreAPI, authToken string, ...) error
func PinIPLDBlockToW3S(ctx context.Context, ipfsNode iface.CoreAPI, authToken string, ...) (cid.Cid, error)
func PublishIPNSRecordForDAGNode(ctx context.Context, ipfscore IPFSCore, authtoken string, cid cid.Cid, ...) error
func PublishIPNSRecordForDAGNodeToW3S(ctx context.Context, authToken string, cid cid.Cid, privkey []byte, ...) error
func PublishSubscriptionMessage(ctx context.Context, ipfscore IPFSCore, topic string, ...) error
func SubscribeToTopic(ctx context.Context, ipfscore IPFSCore, topic string) error
type File
type IPFSCore
- func StartIPFSNode(ctx context.Context, privkey []byte, pubkey []byte) (*IPFSCore, error)
- func (store *IPFSCore) Get(ctx context.Context, key string) ([]byte, error)
- func (store *IPFSCore) Has(ctx context.Context, key string) (bool, error)
- func (store *IPFSCore) OpenRead(lnkCtx linking.LinkContext, lnk datamodel.Link) (io.Reader, error)
- func (store *IPFSCore) OpenWrite(lnkCtx linking.LinkContext, lnk datamodel.Link) (io.Writer, linking.BlockWriteCommitter, error)
- func (store *IPFSCore) Put(ctx context.Context, key string, data []byte) error
- func (store *IPFSCore) PutIPFSBlock(ctx context.Context, data []byte) (cid.Cid, error)
type IPFSLinkWriter
- func (w *IPFSLinkWriter) BlockWriteCommit(lnk datamodel.Link) error
- func (w *IPFSLinkWriter) Write(d []byte) (int, error)
type SubscriptionMessage
- func GetSubscriptionMessages(ctx context.Context, ipfscore IPFSCore, topic string) ([]SubscriptionMessage, error)

Constants ¶

This section is empty.

Variables ¶

View Source

var Files []File

View Source

var IPLDLinkPrototype cidlink.LinkPrototype = cidlink.LinkPrototype{
	Prefix: cid.Prefix{
		Version:  1,
		Codec:    cid.DagJSON,
		MhType:   mh.SHA3_384,
		MhLength: 48,
	}}

View Source

var IPLDNodePrototype datamodel.NodePrototype = basicnode.Prototype.Any

View Source

var Messages = list.New()

View Source

var Subscriptions map[string]iface.PubSubSubscription = make(map[string]iface.PubSubSubscription)

Functions ¶

func GenerateIPFSNodeKeyPair ¶

func GenerateIPFSNodeKeyPair() ([]byte, []byte, error)

func GenerateIPNSKeyPair ¶

func GenerateIPNSKeyPair() ([]byte, []byte, error)

func GetIPFSNodeIdentity ¶

func GetIPFSNodeIdentity(pubb []byte) peer.ID

func GetIPFSNodeIdentityFromPublicKeyName ¶

func GetIPFSNodeIdentityFromPublicKeyName(key string) (peer.ID, error)

func GetIPNSPublicKeyName ¶

func GetIPNSPublicKeyName(pubb []byte) (string, error)

func GetIPNSRecordFromW3S ¶

func GetIPNSRecordFromW3S(ctx context.Context, authToken string, name string) (cid.Cid, error)

func GetSubscriptionPeers ¶

func GetSubscriptionPeers(ctx context.Context, ipfscore IPFSCore, topic string) ([]peer.ID, error)

func GetSubscriptionTopics ¶

func GetSubscriptionTopics(ctx context.Context, ipfscore IPFSCore) ([]string, error)

func PinIPFSBlockToW3S ¶

func PinIPFSBlockToW3S(ctx context.Context, ipfs iface.CoreAPI, authToken string, block *blocks.BasicBlock) error

func PinIPLDBlockToW3S ¶

func PinIPLDBlockToW3S(ctx context.Context, ipfsNode iface.CoreAPI, authToken string, block *blocks.BasicBlock) (cid.Cid, error)

func PublishIPNSRecordForDAGNode ¶

func PublishIPNSRecordForDAGNode(ctx context.Context, ipfscore IPFSCore, authtoken string, cid cid.Cid, keyname string, privkey []byte, pubkey []byte) error

func PublishIPNSRecordForDAGNodeToW3S ¶

func PublishIPNSRecordForDAGNodeToW3S(ctx context.Context, authToken string, cid cid.Cid, privkey []byte, pubkey []byte) error

func PublishSubscriptionMessage ¶

func PublishSubscriptionMessage(ctx context.Context, ipfscore IPFSCore, topic string, message SubscriptionMessage) error

func SubscribeToTopic ¶

func SubscribeToTopic(ctx context.Context, ipfscore IPFSCore, topic string) error

Types ¶

type File ¶

type File struct {
	Cid  string
	Size int
}

type IPFSCore ¶

type IPFSCore struct {
	Ctx      context.Context
	Api      iface.CoreAPI
	Node     ipfsCore.IpfsNode
	Shutdown func()
	LS       linking.LinkSystem
	W3S      w3s.Client
}

func StartIPFSNode ¶

func StartIPFSNode(ctx context.Context, privkey []byte, pubkey []byte) (*IPFSCore, error)

func (*IPFSCore) Get ¶

func (store *IPFSCore) Get(ctx context.Context, key string) ([]byte, error)

func (*IPFSCore) Has ¶

func (store *IPFSCore) Has(ctx context.Context, key string) (bool, error)

func (*IPFSCore) OpenRead ¶

func (store *IPFSCore) OpenRead(lnkCtx linking.LinkContext, lnk datamodel.Link) (io.Reader, error)

func (*IPFSCore) OpenWrite ¶

func (store *IPFSCore) OpenWrite(lnkCtx linking.LinkContext, lnk datamodel.Link) (io.Writer, linking.BlockWriteCommitter, error)

func (*IPFSCore) Put ¶

func (store *IPFSCore) Put(ctx context.Context, key string, data []byte) error

func (*IPFSCore) PutIPFSBlock ¶

func (store *IPFSCore) PutIPFSBlock(ctx context.Context, data []byte) (cid.Cid, error)

type IPFSLinkWriter ¶

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

func (*IPFSLinkWriter) BlockWriteCommit ¶

func (w *IPFSLinkWriter) BlockWriteCommit(lnk datamodel.Link) error

func (*IPFSLinkWriter) Write ¶

func (w *IPFSLinkWriter) Write(d []byte) (int, error)

type SubscriptionMessage ¶

type SubscriptionMessage struct {
	Did   string
	Type  string
	Data  string
	Time  time.Time
	Topic string
	Read  bool
}

swagger:response message

func GetSubscriptionMessages ¶

func GetSubscriptionMessages(ctx context.Context, ipfscore IPFSCore, topic string) ([]SubscriptionMessage, error)

Source Files ¶

View all Source files

ipfs.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL