-
Notifications
You must be signed in to change notification settings - Fork 0
/
job_context.go
67 lines (56 loc) · 1.66 KB
/
job_context.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
// Copyright 2018 The Harbor Authors. All rights reserved.
package env
import (
"context"
"github.com/vmware/harbor/src/jobservice/logger"
)
//JobContext is combination of BaseContext and other job specified resources.
//JobContext will be the real execution context for one job.
type JobContext interface {
//Build the context based on the parent context
//
//dep JobData : Dependencies for building the context, just in case that the build
//function need some external info
//
//Returns:
// new JobContext based on the parent one
// error if meet any problems
Build(dep JobData) (JobContext, error)
//Get property from the context
//
//prop string : key of the context property
//
//Returns:
// The data of the specified context property if have
// bool to indicate if the property existing
Get(prop string) (interface{}, bool)
//SystemContext returns the system context
//
//Returns:
// context.Context
SystemContext() context.Context
//Checkin is bridge func for reporting detailed status
//
//status string : detailed status
//
//Returns:
// error if meet any problems
Checkin(status string) error
//OPCommand return the control operational command like stop/cancel if have
//
//Returns:
// op command if have
// flag to indicate if have command
OPCommand() (string, bool)
//Return the logger
GetLogger() logger.Interface
}
//JobData defines job context dependencies.
type JobData struct {
ID string
Name string
Args map[string]interface{}
ExtraData map[string]interface{}
}
//JobContextInitializer is a func to initialize the concrete job context
type JobContextInitializer func(ctx *Context) (JobContext, error)