The highest tagged major version is
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewDataTransfer ¶
func NewDataTransfer(ds datastore.Batching, cidListsDir string, dataTransferNetwork network.DataTransferNetwork, transport datatransfer.Transport, storedCounter *storedcounter.StoredCounter, options ...DataTransferOption) (datatransfer.Manager, error)
NewDataTransfer initializes a new instance of a data transfer manager
Types ¶
type ChannelDataTransferType ¶ added in v0.9.0
type ChannelDataTransferType int
ChannelDataTransferType identifies the type of a data transfer channel for the purposes of a restart
const ( // ManagerPeerCreatePull is the type of a channel wherein the manager peer created a Pull Data Transfer ManagerPeerCreatePull ChannelDataTransferType = iota // ManagerPeerCreatePush is the type of a channel wherein the manager peer created a Push Data Transfer ManagerPeerCreatePush // ManagerPeerReceivePull is the type of a channel wherein the manager peer received a Pull Data Transfer Request ManagerPeerReceivePull // ManagerPeerReceivePush is the type of a channel wherein the manager peer received a Push Data Transfer Request ManagerPeerReceivePush )
type DataTransferOption ¶ added in v0.9.0
type DataTransferOption func(*manager)
DataTransferOption configures the data transfer manager
func ChannelRemoveTimeout ¶ added in v0.9.0
func ChannelRemoveTimeout(timeout time.Duration) DataTransferOption
ChannelRemoveTimeout sets the timeout after which channels are removed from the manager
Source Files
Click to show internal directories.
Click to hide internal directories.