The highest tagged major version is v2.

graphsync

package

v0.4.0 Latest Latest Go to latest Published: Jul 8, 2020 License: Apache-2.0, MIT Imports: 11 Imported by: 24

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/filecoin-project/go-data-transfer

Links

Open Source Insights

Documentation ¶

Index ¶

type Transport
- func NewTransport(peerID peer.ID, gs graphsync.GraphExchange) *Transport

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Transport ¶

type Transport struct {
	// contains filtered or unexported fields
}

Transport manages graphsync hooks for data transfer, translating from graphsync hooks to semantic data transfer events

func NewTransport ¶

func NewTransport(peerID peer.ID, gs graphsync.GraphExchange) *Transport

NewTransport makes a new hooks manager with the given hook events interface

func (*Transport) CleanupChannel ¶

func (t *Transport) CleanupChannel(chid datatransfer.ChannelID)

CleanupChannel is called on the otherside of a cancel - removes any associated data for the channel

func (*Transport) CloseChannel ¶

func (t *Transport) CloseChannel(ctx context.Context, chid datatransfer.ChannelID) error

CloseChannel closes the given channel

func (*Transport) OpenChannel ¶

func (t *Transport) OpenChannel(ctx context.Context,
	dataSender peer.ID,
	channelID datatransfer.ChannelID,
	root ipld.Link,
	stor ipld.Node,
	msg message.DataTransferMessage) error

OpenChannel initiates an outgoing request for the other peer to send data to us on this channel Note: from a data transfer symantic standpoint, it doesn't matter if the request is push or pull -- OpenChannel is called by the party that is intending to receive data

func (*Transport) PauseChannel ¶

func (t *Transport) PauseChannel(ctx context.Context,
	chid datatransfer.ChannelID,
) error

PauseChannel paused the given channel ID

func (*Transport) ResumeChannel ¶

func (t *Transport) ResumeChannel(ctx context.Context,
	msg message.DataTransferMessage,
	chid datatransfer.ChannelID,
) error

ResumeChannel resumes the given channel

func (*Transport) SetEventHandler ¶

func (t *Transport) SetEventHandler(events transport.Events) error

SetEventHandler sets the handler for events on channels

Source Files ¶

View all Source files

graphsync.go

Directories ¶

Path	Synopsis
extension

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