-
Notifications
You must be signed in to change notification settings - Fork 0
/
init.go
38 lines (27 loc) · 1.92 KB
/
init.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
package worker
// init registers available TaskRunner implementations for worker tasks.
// This setup allows the worker package to instantiate specific task runners
// based on task names, facilitating a dynamic task execution environment.
func init() {
// RegisterTaskRunner associates a string identifier with a TaskRunner constructor.
// When a task with the corresponding name is processed, the associated constructor
// is used to create an instance of the TaskRunner to execute the task.
// Registers a TaskRunner for retrieving Kubernetes pods.
RegisterTaskRunner("CrewGetPods", func() TaskRunner { return &CrewGetPods{} })
// Registers a TaskRunner for checking the health of Kubernetes pods.
RegisterTaskRunner("CrewCheckHealthPods", func() TaskRunner { return &CrewProcessCheckHealthTask{} })
// Registers a TaskRunner for an alternate method of retrieving Kubernetes pods.
RegisterTaskRunner("CrewGetPodsTaskRunner", func() TaskRunner { return &CrewGetPodsTaskRunner{} })
// Registers a TaskRunner for labeling Kubernetes pods.
RegisterTaskRunner("CrewWriteLabelPods", func() TaskRunner { return &CrewLabelPodsTaskRunner{} })
// Register the new TaskRunner for managing deployments.
RegisterTaskRunner("CrewManageDeployments", func() TaskRunner { return &CrewManageDeployments{} })
// Register the new TaskRunner for scaling deployments.
RegisterTaskRunner("CrewScaleDeployments", func() TaskRunner { return &CrewScaleDeployments{} })
// Register the new TaskRunner for updating image deployments.
RegisterTaskRunner("CrewUpdateImageDeployments", func() TaskRunner { return &CrewUpdateImageDeployments{} })
// Register the new TaskRunner for create storage pvc
RegisterTaskRunner("CrewCreatePVCStorage", func() TaskRunner { return &CrewCreatePVCStorage{} })
// Register the new TaskRunner for update network policy
RegisterTaskRunner("CrewUpdateNetworkPolicy", func() TaskRunner { return &CrewUpdateNetworkPolicy{} })
}