impl

package
v2.0.0-rc7 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 22, 2023 License: Apache-2.0, MIT Imports: 28 Imported by: 15

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewDataTransfer

func NewDataTransfer(ds datastore.Batching, dataTransferNetwork network.DataTransferNetwork, transport datatransfer.Transport, options ...DataTransferOption) (datatransfer.Manager, error)

NewDataTransfer initializes a new instance of a data transfer manager

Types

type ChannelDataTransferType

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

type DataTransferOption func(*manager)

DataTransferOption configures the data transfer manager

func ChannelRestartConfig

func ChannelRestartConfig(cfg channelmonitor.Config) DataTransferOption

ChannelRestartConfig sets the configuration options for automatically restarting push and pull channels

Jump to

Keyboard shortcuts

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