transfer

Documentation

Index

• type IManager
  • func NewManager(db *gorm.DB, fc *filclient.FilClient, log *zap.SugaredLogger, ...) IManager

Types

type IManager

type IManager interface {
	RestartAllTransfersForLocation(ctx context.Context, loc string) error
	RestartTransfer(ctx context.Context, loc string, chanid datatransfer.ChannelID, d model.ContentDeal) error
	GetProviderDealStatus(ctx context.Context, d *model.ContentDeal, maddr address.Address, dealUUID *uuid.UUID) (*storagemarket.ProviderDealState, bool, 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
	SubscribeEventListener(ctx context.Context) error
}

func NewManager

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