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
func PushChannelRestartConfig ¶ added in v1.2.4
func PushChannelRestartConfig( interval time.Duration, checksPerInterval uint32, minBytesSent uint64, restartBackoff time.Duration, ) DataTransferOption
PushChannelRestartConfig sets the configuration options for automatically restarting push channels - interval is the time over which minBytesSent must have been sent - checksPerInterval is the number of times to check per interval - minBytesSent is the minimum amount of data that must have been sent over the interval - restartBackoff is the time to wait before checking again for restarts
Source Files