impl

package

v0.4.5 Latest Latest Go to latest Published: Dec 5, 2021 License: MIT Imports: 26 Imported by: 0

Details

This section is empty.

This section is empty.

func FetchBlock(ctx context.Context, exchange graphsync.GraphExchange, ipfspeer *peer.AddrInfo, c ipld.Link) error

func NewAgent(ctx context.Context, gsynchost host.Host, router string) gsync.GraphExchange

func NewEdge(ctx context.Context, gsynchost host.Host, router string) string

func NewPeer(ctx context.Context, addr string) host.Host

func NewRouter(ctx context.Context, gsynchost host.Host, s anconsync.Storage, peerhost string) (gsync.GraphExchange, *peer.AddrInfo)

func PrintProgress(ctx context.Context, pgChan <-chan gsync.ResponseProgress)

VerifyHasErrors verifies that at least one error was sent over a channel

func PushBlock(ctx context.Context, exchange graphsync.GraphExchange, ipfspeer *peer.AddrInfo, c ipld.Link) error

func ReadCAR() ([]cid.Cid, blocks.Block, datamodel.Node, error)

WriteCAR

func VerifyHasErrors(ctx context.Context, errChan <-chan error) error

VerifyHasErrors verifies that at least one error was sent over a channel

type ReceivedMessage struct {
	Message gsmsg.GraphSyncMessage
	Sender  peer.ID
}

type Receiver struct {
	MessageReceived chan ReceivedMessage
}

Receiver is an interface for receiving messages from the GraphSyncNetwork.

func (r *Receiver) Connected(p peer.ID)

func (r *Receiver) Disconnected(p peer.ID)

func (r *Receiver) ReceiveError(_ peer.ID, err error)

func (r *Receiver) ReceiveMessage(
	ctx context.Context,
	sender peer.ID,
	incoming gsmsg.GraphSyncMessage)