tasks

package

v0.5.1 Latest Latest Go to latest Published: Mar 17, 2026 License: BSD-3-Clause Imports: 16 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/SwissOpenEM/scicat-globus-proxy

Links

Open Source Insights

Documentation ¶

Index ¶

func CreateGlobusTransferScicatJob(scicatUrl string, scicatToken string, ownerGroup string, datasetPid string, ...) (jobs.ScicatJob, error)
func DeleteScicatJob(scicatUrl string, scicatToken string, jobId string) error
func RestoreGlobusTransferJobsFromScicat(scicatUrl string, serviceUser serviceuser.ScicatServiceUser, pool TaskPool) error
func UpdateGlobusTransferScicatJob(scicatUrl string, scicatToken string, jobId string, statusCode string, ...) (jobs.ScicatJob, error)
type ArchivalJobInfo
type JobDeleteNotExist
- func (e *JobDeleteNotExist) Error() string
type JobNotExistError
- func (e *JobNotExistError) Error() string
type TaskPool
- func CreateTaskPool(scicatUrl string, globusClient globus.GlobusClient, ...) TaskPool

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func CreateGlobusTransferScicatJob ¶

func CreateGlobusTransferScicatJob(scicatUrl string, scicatToken string, ownerGroup string, datasetPid string, globusTaskId string) (jobs.ScicatJob, error)

func DeleteScicatJob ¶

func DeleteScicatJob(scicatUrl string, scicatToken string, jobId string) error

func RestoreGlobusTransferJobsFromScicat ¶

func RestoreGlobusTransferJobsFromScicat(scicatUrl string, serviceUser serviceuser.ScicatServiceUser, pool TaskPool) error

func UpdateGlobusTransferScicatJob ¶

func UpdateGlobusTransferScicatJob(scicatUrl string, scicatToken string, jobId string, statusCode string, statusMessage string, jobStatus jobs.JobResultObject) (jobs.ScicatJob, error)

Types ¶

type ArchivalJobInfo ¶ added in v0.5.0

type ArchivalJobInfo struct {
	OwnerUser    string
	OwnerGroup   string
	AutoArchive  bool
	ContactEmail string
}

type JobDeleteNotExist ¶

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

func (*JobDeleteNotExist) Error ¶

func (e *JobDeleteNotExist) Error() string

type JobNotExistError ¶

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

func (*JobNotExistError) Error ¶

func (e *JobNotExistError) Error() string

type TaskPool ¶

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

func CreateTaskPool ¶

func CreateTaskPool(scicatUrl string, globusClient globus.GlobusClient, scicatServiceUser serviceuser.ScicatServiceUser, maxConcurrency int, queueSize int, taskPollInterval uint) TaskPool

func (TaskPool) AddTransferTask ¶

func (tp TaskPool) AddTransferTask(globusTaskId string, datasetPid string, scicatJobId string, archivalJobInfo ArchivalJobInfo) pond.Task

func (TaskPool) CanSubmitJob ¶

func (tp TaskPool) CanSubmitJob() bool

func (TaskPool) CancelTransferTask ¶

func (tp TaskPool) CancelTransferTask(scicatJobId string) error

func (TaskPool) DeleteTransferTask ¶

func (tp TaskPool) DeleteTransferTask(scicatJobId string) error

func (TaskPool) IsQueueSizeLimited ¶

func (tp TaskPool) IsQueueSizeLimited() bool

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL