Documentation ¶
Index ¶
- func CreateNode(ctx context.Context, repoPath string) (*core.IpfsNode, ifGoIpfsCore.CoreAPI, error)
- func SetupPlugins(path string) error
- type DataLogEvent
- type EventOptions
- type IpfsLog
- 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
- type RemoteWrite
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateNode ¶
func SetupPlugins ¶
Types ¶
type DataLogEvent ¶
type DataLogEvent struct {
Payload []byte
}
func NewDataLogEvent ¶
func NewDataLogEvent(b []byte) DataLogEvent
type EventOptions ¶
type IpfsLog ¶
type IpfsLog struct {
// contains filtered or unexported fields
}
func NewIpfsLog ¶
func (*IpfsLog) AnnounceConnect ¶
type LocalWrite ¶
func NewLocalWrite ¶
func NewLocalWrite(heads []*entry.Entry) LocalWrite
func (*LocalWrite) Marshal ¶
func (m *LocalWrite) Marshal() []byte
type RemoteWrite ¶
func NewRemoteWrite ¶
func NewRemoteWrite(from core.PeerID, heads []*entry.Entry) RemoteWrite
func (*RemoteWrite) Marshal ¶
func (m *RemoteWrite) Marshal() []byte
Click to show internal directories.
Click to hide internal directories.