pinner

type PinFunc func(context.Context, *PinningOperation, PinProgressCB) error

type PinManager struct {
	RunPinFunc       PinFunc
	StatusChangeFunc PinStatusFunc

	QueueDataDir string
	// contains filtered or unexported fields
}

type PinManagerOpts struct {
	MaxActivePerUser int
	QueueDataDir     string
}

type PinProgressCB func(int64)

type PinStatusFunc func(contID uint, location string, status types.PinningStatus) error

type PinningOperation struct {
	Obj   cid.Cid
	Name  string
	Peers []*peer.AddrInfo
	Meta  string

	Status types.PinningStatus

	UserId  uint
	ContId  uint
	Replace uint

	LastUpdate time.Time

	Started     time.Time
	NumFetched  int
	SizeFetched int64
	FetchErr    error
	EndTime     time.Time

	Location string

	SkipLimiter bool

	MakeDeal bool
	// contains filtered or unexported fields
}

type PinningOperationData struct {
	ContId uint
}