diff options
| author | zhengxinwei <zhengxinwei@huawei.com> | 2024-01-04 15:27:04 +0800 |
|---|---|---|
| committer | zhengxinwei-f <zhengxinwei@huawei.com> | 2024-01-16 09:35:44 +0800 |
| commit | b1c1c6a8e5442fff2b4d932060648e009f639df1 (patch) | |
| tree | 575f35f9559894e995060f15b029ff73f2d23282 /common | |
| parent | notify the task manager of the task status (diff) | |
| download | kubeedge-b1c1c6a8e5442fff2b4d932060648e009f639df1.tar.gz | |
Implement task manager to complete cloud edge task execution
Signed-off-by: zhengxinwei-f <zhengxinwei@huawei.com>
Diffstat (limited to 'common')
| -rw-r--r-- | common/constants/default.go | 3 | ||||
| -rw-r--r-- | common/types/types.go | 14 |
2 files changed, 11 insertions, 6 deletions
diff --git a/common/constants/default.go b/common/constants/default.go index 07b642816..d3cc65410 100644 --- a/common/constants/default.go +++ b/common/constants/default.go @@ -31,6 +31,7 @@ const ( DefaultCAURL = "/ca.crt" DefaultCertURL = "/edge.crt" DefaultNodeUpgradeURL = "/nodeupgrade" + DefaultTaskStateReportURL = "/task/{taskType}/name/{taskID}/node/{nodeID}/status" DefaultServiceAccountIssuer = "https://kubernetes.default.svc.cluster.local" // Edged @@ -113,7 +114,7 @@ const ( DefaultDeviceModelEventBuffer = 1 DefaultUpdateDeviceStatusWorkers = 1 - // NodeUpgradeJobController + // TaskManager DefaultNodeUpgradeJobStatusBuffer = 1024 DefaultNodeUpgradeJobEventBuffer = 1 DefaultNodeUpgradeJobWorkers = 1 diff --git a/common/types/types.go b/common/types/types.go index 74c7cf6ea..5cf6856e4 100644 --- a/common/types/types.go +++ b/common/types/types.go @@ -50,12 +50,16 @@ type NodeUpgradeJobResponse struct { Reason string } -type TaskStatus struct { +// NodePreCheckRequest is pre-check msg coming from cloud to edge +type NodePreCheckRequest struct { + CheckItem []string +} + +type NodeTaskRequest struct { + TaskID string Type string - Status string - Event string - Action string - Reason string + State string + Item interface{} } // ObjectResp is the object that api-server response |