stash

Documentation

Index

• func Init()
• type DestinationCountResult
• 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 StashRpcHandler
  • func (s *StashRpcHandler) GetDSFailedJobs(arg string, result *string) (err error)
  • func (s *StashRpcHandler) GetDSJobCount(arg string, result *string) (err error)
  • func (s *StashRpcHandler) GetDSList(_ string, result *string) (err error)
  • func (s *StashRpcHandler) GetDSStats(dsName string, result *string) (err error)
  • func (s *StashRpcHandler) GetJobByID(arg string, result *string) (err error)
  • func (s *StashRpcHandler) GetJobIDStatus(arg string, result *string) (err error)
• type StoreErrorOutputT

Functions

func Init

func Init()

Types

type DestinationCountResult

type DestinationCountResult struct {
	Count    int
	DestName string
	Error    string
}

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 StashRpcHandler

type StashRpcHandler struct {
	ReadOnlyJobsDB jobsdb.ReadonlyJobsDB
}

func (*StashRpcHandler) GetDSFailedJobs

func (s *StashRpcHandler) GetDSFailedJobs(arg string, result *string) (err error)

func (*StashRpcHandler) GetDSJobCount

func (s *StashRpcHandler) GetDSJobCount(arg string, result *string) (err error)

func (*StashRpcHandler) GetDSList

func (s *StashRpcHandler) GetDSList(_ string, result *string) (err error)

func (*StashRpcHandler) GetDSStats

func (s *StashRpcHandler) GetDSStats(dsName string, result *string) (err error)

GetDSStats

ProcErrorsByDestinationCount ================================================================================ │───────│─────────────│──────────────────────────────────│ │ COUNT │ DESTINATION │ ERROR │ │───────│─────────────│──────────────────────────────────│ │ 3 │ GA │ "server side identify is not on" │ │───────│─────────────│──────────────────────────────────│

func (*StashRpcHandler) GetJobByID

func (s *StashRpcHandler) GetJobByID(arg string, result *string) (err error)

func (*StashRpcHandler) GetJobIDStatus

func (s *StashRpcHandler) GetJobIDStatus(arg string, result *string) (err error)

type StoreErrorOutputT

type StoreErrorOutputT struct {
	Location string
	Error    error
}