api

package
v0.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 12, 2022 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Common

type Common interface {
	Add(context.Context, string) (chan PBar, error)
	Add2(context.Context, string, int) (chan PBar, error)
	Get(context.Context, cid.Cid, string) (chan PBar, error)
}

type Dag

type Dag interface {
	DagStat(context.Context, cid.Cid, uint) (*format.NodeStat, error)
	DagSync(context.Context, []cid.Cid, int) (chan string, error)
	DagExport(context.Context, cid.Cid, string, bool, int, bool) (chan PBar, error)
	DagHas(context.Context, cid.Cid) (bool, error)
	DagImport(context.Context, string) (chan PBar, error)
}

type FullNode

type FullNode interface {
	Common
	Net
	Dag
}

type FullNodeClient

type FullNodeClient struct {
	NetConnectedness func(context.Context, peer.ID) (network.Connectedness, error)
	NetPeers         func(context.Context) ([]peer.AddrInfo, error)
	NetConnect       func(context.Context, peer.AddrInfo) error
	NetAddrsListen   func(context.Context) (peer.AddrInfo, error)
	NetDisconnect    func(context.Context, peer.ID) error

	ID        func(context.Context) (peer.ID, error)
	DagStat   func(context.Context, cid.Cid, uint) (*format.NodeStat, error)
	DagSync   func(context.Context, []cid.Cid, int) (chan string, error)
	DagExport func(context.Context, cid.Cid, string, bool, int, bool) (chan PBar, error)
	DagImport func(context.Context, string) (chan PBar, error)
	DagHas    func(context.Context, cid.Cid) (bool, error)
	Add       func(context.Context, string) (chan PBar, error)
	Add2      func(context.Context, string, int) (chan PBar, error)
	Get       func(context.Context, cid.Cid, string) (chan PBar, error)
}

type FullNodeClientApi

type FullNodeClientApi struct {
	Emb *FullNodeClient
}

func (*FullNodeClientApi) Add

func (a *FullNodeClientApi) Add(ctx context.Context, path string) (chan PBar, error)

func (*FullNodeClientApi) Add2

func (a *FullNodeClientApi) Add2(ctx context.Context, path string, br int) (chan PBar, error)

func (*FullNodeClientApi) DagExport

func (a *FullNodeClientApi) DagExport(ctx context.Context, cid cid.Cid, path string, pad bool, batchNum int, swarm bool) (chan PBar, error)

func (*FullNodeClientApi) DagHas

func (a *FullNodeClientApi) DagHas(ctx context.Context, cid cid.Cid) (bool, error)

func (*FullNodeClientApi) DagImport

func (a *FullNodeClientApi) DagImport(ctx context.Context, path string) (chan PBar, error)

func (*FullNodeClientApi) DagStat

func (a *FullNodeClientApi) DagStat(ctx context.Context, cid cid.Cid, timeout uint) (*format.NodeStat, error)

func (*FullNodeClientApi) DagSync

func (a *FullNodeClientApi) DagSync(ctx context.Context, cids []cid.Cid, concur int) (chan string, error)

func (*FullNodeClientApi) Get

func (a *FullNodeClientApi) Get(ctx context.Context, cid cid.Cid, path string) (chan PBar, error)

func (*FullNodeClientApi) ID

func (a *FullNodeClientApi) ID(ctx context.Context) (peer.ID, error)

func (*FullNodeClientApi) NetAddrsListen

func (a *FullNodeClientApi) NetAddrsListen(ctx context.Context) (peer.AddrInfo, error)

func (*FullNodeClientApi) NetConnect

func (a *FullNodeClientApi) NetConnect(ctx context.Context, p peer.AddrInfo) error

func (*FullNodeClientApi) NetConnectedness

func (a *FullNodeClientApi) NetConnectedness(ctx context.Context, pid peer.ID) (network.Connectedness, error)

func (*FullNodeClientApi) NetDisconnect

func (a *FullNodeClientApi) NetDisconnect(ctx context.Context, p peer.ID) error

func (*FullNodeClientApi) NetPeers

func (a *FullNodeClientApi) NetPeers(ctx context.Context) ([]peer.AddrInfo, error)

type Net

type Net interface {
	NetConnectedness(context.Context, peer.ID) (network.Connectedness, error)
	NetPeers(context.Context) ([]peer.AddrInfo, error)
	NetConnect(context.Context, peer.AddrInfo) error
	NetAddrsListen(context.Context) (peer.AddrInfo, error)
	NetDisconnect(context.Context, peer.ID) error

	ID(context.Context) (peer.ID, error)
}

type PBar

type PBar struct {
	Total   int64
	Current int64
	Err     string
	Msg     string
}

Jump to

Keyboard shortcuts

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