Versions in this module Expand all Collapse all v0 v0.2.0 Apr 23, 2024 v0.1.0 Nov 8, 2022 Changes in this version + func CreateNode(ctx context.Context, repoPath string) (*core.IpfsNode, ifGoIpfsCore.CoreAPI, error) + func SetupPlugins(path string) error + type DataLogEvent struct + Payload []byte + func NewDataLogEvent(b []byte) DataLogEvent + type EventOptions struct + Cache datastore.Datastore + CloseKeystore func() error + Directory string + IO ipfslog.IO + Identity *idp.Identity + IpfsLog ipfslog.Log + Keystore keystore.Interface + Logger *zap.Logger + Pubsub pubsub.PubSubInterface + type IpfsLog struct + func NewIpfsLog(ctx context.Context, ipfs iface.CoreAPI, dbname string, options *EventOptions) (*IpfsLog, error) + func (ev *IpfsLog) AnnounceConnect(ctx context.Context, node *ipfscore.IpfsNode) error + func (ev *IpfsLog) Append(ctx context.Context, payload []byte) (cid.Cid, error) + func (ev *IpfsLog) Close() error + func (ev *IpfsLog) Get(cid cid.Cid) []byte + func (ev *IpfsLog) List() [][]byte + func (ev *IpfsLog) LoadDisk(ctx context.Context) error + func (ev *IpfsLog) WatchWriteEvent(ctx context.Context) (<-chan []byte, error) + type LocalWrite struct + Heads []*entry.Entry + func NewLocalWrite(heads []*entry.Entry) LocalWrite + func (m *LocalWrite) Marshal() []byte + type RemoteWrite struct + From core.PeerID + Heads []*entry.Entry + func NewRemoteWrite(from core.PeerID, heads []*entry.Entry) RemoteWrite + func (m *RemoteWrite) Marshal() []byte