api

Documentation

Index

• type Common
• type Dag
• type FullNode
• type FullNodeClient
• type FullNodeClientApi
  • func (a *FullNodeClientApi) Add(ctx context.Context, path string) (chan PBar, error)
  • func (a *FullNodeClientApi) Add2(ctx context.Context, path string, br int) (chan PBar, error)
  • func (a *FullNodeClientApi) DagExport(ctx context.Context, cid cid.Cid, path string, pad bool, batchNum int, ...) (chan PBar, error)
  • func (a *FullNodeClientApi) DagHas(ctx context.Context, cid cid.Cid) (bool, error)
  • func (a *FullNodeClientApi) DagImport(ctx context.Context, path string) (chan PBar, error)
  • func (a *FullNodeClientApi) DagStat(ctx context.Context, cid cid.Cid, timeout uint) (*format.NodeStat, error)
  • func (a *FullNodeClientApi) DagSync(ctx context.Context, cids []cid.Cid, concur int) (chan string, error)
  • func (a *FullNodeClientApi) Get(ctx context.Context, cid cid.Cid, path string) (chan PBar, error)
  • func (a *FullNodeClientApi) ID(ctx context.Context) (peer.ID, error)
  • func (a *FullNodeClientApi) NetAddrsListen(ctx context.Context) (peer.AddrInfo, error)
  • func (a *FullNodeClientApi) NetConnect(ctx context.Context, p peer.AddrInfo) error
  • func (a *FullNodeClientApi) NetConnectedness(ctx context.Context, pid peer.ID) (network.Connectedness, error)
  • func (a *FullNodeClientApi) NetDisconnect(ctx context.Context, p peer.ID) error
  • func (a *FullNodeClientApi) NetPeers(ctx context.Context) ([]peer.AddrInfo, error)
• type Net
• type PBar

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
}