handler

Documentation

Index

• Variables
• func DeleteJob(ctx context.Context, inspector *asynq.Inspector) ...
• func GetDacByProject(ctx context.Context, cfg config.Configuration) func(params operations.GetDacProjectNumberParams) middleware.Responder
• func GetJob(ctx context.Context, inspector *asynq.Inspector) ...
• func GetJobs(ctx context.Context, inspector *asynq.Inspector) ...
• func GetPing(cfg config.Configuration) func(params operations.GetPingParams) middleware.Responder
• func ListDir(ctx context.Context) ...
• func NewJob(ctx context.Context, client *asynq.Client, rdb *redis.Client) ...
• func NewJobs(ctx context.Context, client *asynq.Client, rdb *redis.Client) ...
• func RescheduleJob(ctx context.Context, client *asynq.Client, inspector *asynq.Inspector) ...

Variables

var (
	// PathProject is the top-leve directory in which directories of active projects are located.
	PathProject string = "/project"

	// StagerJobQueueName is the queue name for stager jobs.
	StagerJobQueueName string = "stager"

	// MaxRetries (i.e. total attempts - 1)
	MaxRetries int = 2

	// RetryIntervalSeconds
	RetryIntervalSeconds int = 1
)

var (
	// NotImplementedError indicates the implementation of the handler is not implemented yet.
	NotImplementedError int64 = 100

	// JobQueueError indicates failure adding/retrieving job from the stager job queue.
	JobQueueError int64 = 101

	// JobDataError indicates invalid job data format causing (de-)serialization failure.
	JobDataError int64 = 102

	// JobCreateError indicates failure creating/registering new job to the stager job queue.
	JobCreateError int64 = 103

	// FileSystemError indicates failure on filesystem operation
	FileSystemError int64 = 104
)

Error code definitions.

Functions

func DeleteJob

func DeleteJob(ctx context.Context, inspector *asynq.Inspector) func(params operations.DeleteJobIDParams, principal *models.Principal) middleware.Responder

DeleteJob cancels the job.

func GetDacByProject

func GetDacByProject(ctx context.Context, cfg config.Configuration) func(params operations.GetDacProjectNumberParams) middleware.Responder

func GetJob

func GetJob(ctx context.Context, inspector *asynq.Inspector) func(params operations.GetJobIDParams, principal *models.Principal) middleware.Responder

GetJob retrieves job information.

func GetJobs

func GetJobs(ctx context.Context, inspector *asynq.Inspector) func(params operations.GetJobsParams, principal *models.Principal) middleware.Responder

GetJobs retrieves all jobs owned by the `principal`.

func GetPing

func GetPing(cfg config.Configuration) func(params operations.GetPingParams) middleware.Responder

GetPing returns dummy string for health check, including the authentication.

func ListDir

func ListDir(ctx context.Context) func(params operations.GetDirParams, principal *models.Principal) middleware.Responder

func NewJob

func NewJob(ctx context.Context, client *asynq.Client, rdb *redis.Client) func(params operations.PostJobParams, principal *models.Principal) middleware.Responder

NewJob registers the incoming transfer request as a new stager job in the queue.

func NewJobs

func NewJobs(ctx context.Context, client *asynq.Client, rdb *redis.Client) func(params operations.PostJobsParams, principal *models.Principal) middleware.Responder

NewJobs registers the incoming transfer request as multiple stager jobs in the queue.

func RescheduleJob

func RescheduleJob(ctx context.Context, client *asynq.Client, inspector *asynq.Inspector) func(params operations.PutJobScheduledIDParams, principal *models.Principal) middleware.Responder

RescheduleJob