impl

Documentation

Index

• func NewDataTransfer(ds datastore.Batching, cidListsDir string, ...) (datatransfer.Manager, error)
• type ChannelDataTransferType
• type DataTransferOption
  • func ChannelRestartConfig(cfg channelmonitor.Config) DataTransferOption

Functions

func NewDataTransfer

func NewDataTransfer(ds datastore.Batching, cidListsDir string, 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