Method CreateTask

pkg/cluster/node.go:253–284

(ctx context.Context, taskType string, state string)

}

func (n *slaveNode) CreateTask(ctx context.Context, taskType string, state string) (int, error) {
	reqBody, err := json.Marshal(&CreateSlaveTask{
		Type:  taskType,
		State: state,
	})
	if err != nil {
		return 0, fmt.Errorf("failed to marshal request body: %w", err)
	}

	resp, err := n.client.Request(
		"PUT",
		constants.APIPrefixSlave+"/task",
		bytes.NewReader(reqBody),
		request.WithContext(ctx),
		request.WithLogger(logging.FromContext(ctx)),
	).CheckHTTPResponse(200).DecodeResponse()
	if err != nil {
		return 0, err
	}

	// 处理列取结果
	if resp.Code != 0 {
		return 0, serializer.NewErrorFromResponse(resp)
	}

	taskId := 0
	if resp.GobDecode(&taskId); taskId > 0 {
		return taskId, nil
	}

	return 0, fmt.Errorf("unexpected response data: %v", resp.Data)
}

func (n *slaveNode) GetTask(ctx context.Context, id int, clearOnComplete bool) (*SlaveTaskSummary, error) {
	resp, err := n.client.Request(