pinner

package

v0.2.4 Latest Latest Go to latest Published: Dec 10, 2022 License: Apache-2.0, MIT Imports: 23 Imported by: 0

Details

This section is empty.

View Source

var DefaultOpts = &PinManagerOpts{
	MaxActivePerUser: 15,
	QueueDataDir:     "/tmp/",
}

This section is empty.

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

type PinManager struct {
	RunPinFunc       PinFunc
	StatusChangeFunc PinStatusFunc

	QueueDataDir string
	// contains filtered or unexported fields
}

func NewPinManager(pinfunc PinFunc, scf PinStatusFunc, opts *PinManagerOpts) *PinManager

func (pm *PinManager) Add(op *operation.PinningOperation)

func (pm *PinManager) PinQueueSize() int

func (pm *PinManager) Run(workers int)

func (pm *PinManager) RunPinningRetryWorker(ctx context.Context, db *gorm.DB, cfg *config.Estuary, cm *contentmgr.ContentManager)

RunPinningRetryWorker re-attempt pinning contents that have not yet been pinned after a period of time

type PinManagerOpts struct {
	MaxActivePerUser int
	QueueDataDir     string
}

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

type PinningOperationData struct {
	ContId uint
}