transfer

Documentation

Index

• type IManager
  • func NewManager(ctx context.Context, db *gorm.DB, fc *filclient.FilClient, ...) (IManager, error)

Types

type IManager

type IManager interface {
	RestartAllTransfersForLocation(ctx context.Context, loc string, done chan struct{}) error
	RestartTransfer(ctx context.Context, loc string, chanid datatransfer.ChannelID, d model.ContentDeal) error
	GetTransferStatus(ctx context.Context, d *model.ContentDeal, contCID cid.Cid, contLoc string) (*filclient.ChannelState, error)
	StartDataTransfer(ctx context.Context, cd *model.ContentDeal) error
	SetDataTransferStartedOrFinished(ctx context.Context, dealDBID uint, chanIDOrTransferID string, st *filclient.ChannelState, isStarted bool) error
	UpdateDataTransferStatus(ctx context.Context, dealDBID uint, chanIDOrTransferID string, st *filclient.ChannelState, isFailed bool, msg string) error
}

func NewManager

func NewManager(ctx context.Context, db *gorm.DB, fc *filclient.FilClient, log *zap.SugaredLogger, shuttleMgr shuttle.IManager) (IManager, error)