stash

Documentation

Index

• func Init()
• type ErrorJob
• type HandleT
  • func New() *HandleT
  • func (st *HandleT) Setup(errorDB jobsdb.JobsDB, transientSource transientsource.Service, ...)
  • func (st *HandleT) Start(ctx context.Context)
• type StoreErrorOutputT

Functions

func Init

func Init()

Types

type ErrorJob

type ErrorJob struct {
	// contains filtered or unexported fields
}

type HandleT

type HandleT struct {
	// contains filtered or unexported fields
}

func New

func New() *HandleT

func (*HandleT) Setup

func (st *HandleT) Setup(
	errorDB jobsdb.JobsDB,
	transientSource transientsource.Service,
	fileuploader fileuploader.Provider,
	adaptiveLimitFunc func(int64) int64,
)

func (*HandleT) Start

func (st *HandleT) Start(ctx context.Context)

type StoreErrorOutputT

type StoreErrorOutputT struct {
	Location string
	Error    error
}