pinner

Documentation

Index

• Variables
• type EstuaryPinManager
  • func NewEstuaryPinManager(pinfunc PinFunc, scf PinStatusFunc, opts *PinManagerOpts, ...) *EstuaryPinManager
  • func (pm *EstuaryPinManager) RunPinningRetryWorker(ctx context.Context, db *gorm.DB, cfg *config.Estuary)
• type PinFunc
• type PinManager
  • func NewShuttlePinManager(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)
• type PinManagerOpts
• type PinStatusFunc
• type PinningOperationData
• type ShuttleManager

Variables

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

Types

type EstuaryPinManager

type EstuaryPinManager struct {
	*PinManager
	// contains filtered or unexported fields
}

func NewEstuaryPinManager

func NewEstuaryPinManager(pinfunc PinFunc, scf PinStatusFunc, opts *PinManagerOpts, cm *contentmgr.ContentManager, shuttleMgr shuttle.IManager) *EstuaryPinManager

func (*EstuaryPinManager) RunPinningRetryWorker

func (pm *EstuaryPinManager) RunPinningRetryWorker(ctx context.Context, db *gorm.DB, cfg *config.Estuary)

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

type PinFunc

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

type PinManager

type PinManager struct {
	RunPinFunc       PinFunc
	StatusChangeFunc PinStatusFunc

	QueueDataDir string
	// contains filtered or unexported fields
}

func NewShuttlePinManager

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

func (*PinManager) Add

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

func (*PinManager) PinQueueSize

func (pm *PinManager) PinQueueSize() int

func (*PinManager) Run

func (pm *PinManager) Run(workers int)

type PinManagerOpts

type PinManagerOpts struct {
	MaxActivePerUser int
	QueueDataDir     string
}

type PinStatusFunc

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

type PinningOperationData

type PinningOperationData struct {
	ContId uint
}

type ShuttleManager

type ShuttleManager struct {
	*PinManager
}