datatransfer

Documentation

Index

• Variables
• type ExecuteParams
• type MockTransport
  • func NewMockTransport() *MockTransport
  • func (t *MockTransport) Execute(ctx context.Context, params ExecuteParams) (chan uint64, error)
  • func (t *MockTransport) SimulateTransfer(ctx context.Context, dealUuid uuid.UUID, size uint64) (chan uint64, error)
  • func (t *MockTransport) Transferred(dealUuid uuid.UUID) uint64
• type OnTransferredFn
• type TransferLocalParams

Variables

var TransferLocal = &transferLocalImpl{}

Types

type ExecuteParams

type ExecuteParams struct {
	TransferType   string
	TransferParams []byte
	DealUuid       uuid.UUID
	FilePath       string
	Size           uint64
}

type MockTransport

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

func NewMockTransport

func NewMockTransport() *MockTransport

func (*MockTransport) Execute

func (t *MockTransport) Execute(ctx context.Context, params ExecuteParams) (chan uint64, error)

func (*MockTransport) SimulateTransfer

func (t *MockTransport) SimulateTransfer(ctx context.Context, dealUuid uuid.UUID, size uint64) (chan uint64, error)

func (*MockTransport) Transferred

func (t *MockTransport) Transferred(dealUuid uuid.UUID) uint64

type OnTransferredFn

type OnTransferredFn func(transferred uint64)

type TransferLocalParams

type TransferLocalParams struct {
	Path string
}