Fix: fix the usage of http client and run crd (#93)

Signed-off-by: FogDong <[email protected]> Signed-off-by: FogDong <[email protected]>
kubevela · Jan 3, 2023 · bca032d · bca032d
1 parent dd7a3c0
commit bca032d
Show file tree

Hide file tree

Showing 5 changed files with 15 additions and 33 deletions.
diff --git a/api/v1alpha1/types.go b/api/v1alpha1/types.go
@@ -101,8 +101,7 @@ type WorkflowRunStatus struct {
 
 // WorkflowSpec defines workflow steps and other attributes
 type WorkflowSpec struct {
-	Mode  *WorkflowExecuteMode `json:"mode,omitempty"`
-	Steps []WorkflowStep       `json:"steps,omitempty"`
+	Steps []WorkflowStep `json:"steps,omitempty"`
 }
 
 // WorkflowExecuteMode defines the mode of workflow execution
@@ -144,6 +143,7 @@ type Workflow struct {
 	metav1.TypeMeta   `json:",inline"`
 	metav1.ObjectMeta `json:"metadata,omitempty"`
 
+	Mode         *WorkflowExecuteMode `json:"mode,omitempty"`
 	WorkflowSpec `json:",inline"`
 }
 

diff --git a/api/v1alpha1/zz_generated.deepcopy.go b/api/v1alpha1/zz_generated.deepcopy.go
diff --git a/charts/vela-workflow/crds/core.oam.dev_workflowruns.yaml b/charts/vela-workflow/crds/core.oam.dev_workflowruns.yaml
@@ -64,17 +64,6 @@ spec:
               workflowSpec:
                 description: WorkflowSpec defines workflow steps and other attributes
                 properties:
-                  mode:
-                    description: WorkflowExecuteMode defines the mode of workflow
-                      execution
-                    properties:
-                      steps:
-                        description: Steps is the mode of workflow steps execution
-                        type: string
-                      subSteps:
-                        description: SubSteps is the mode of workflow sub steps execution
-                        type: string
-                    type: object
                   steps:
                     items:
                       description: WorkflowStep defines how to execute a workflow

diff --git a/controllers/workflow_test.go b/controllers/workflow_test.go
@@ -96,10 +96,10 @@ var _ = Describe("Test Workflow", func() {
 				Name:      "workflow",
 				Namespace: namespace,
 			},
+			Mode: &v1alpha1.WorkflowExecuteMode{
+				Steps: v1alpha1.WorkflowModeDAG,
+			},
 			WorkflowSpec: v1alpha1.WorkflowSpec{
-				Mode: &v1alpha1.WorkflowExecuteMode{
-					Steps: v1alpha1.WorkflowModeDAG,
-				},
 				Steps: []v1alpha1.WorkflowStep{
 					{
 						WorkflowStepBase: v1alpha1.WorkflowStepBase{

diff --git a/pkg/providers/http/do.go b/pkg/providers/http/do.go
@@ -46,16 +46,11 @@ const (
 )
 
 var (
-	defaultClient *http.Client
-	rateLimiter   *ratelimiter.RateLimiter
+	rateLimiter *ratelimiter.RateLimiter
 )
 
 func init() {
 	rateLimiter = ratelimiter.NewRateLimiter(128)
-	defaultClient = &http.Client{
-		Transport: http.DefaultTransport,
-		Timeout:   time.Second * 3,
-	}
 }
 
 type provider struct {
@@ -79,7 +74,10 @@ func (h *provider) runHTTP(ctx monitorContext.Context, v *value.Value) (interfac
 		header, trailer http.Header
 		r               io.Reader
 	)
-	initDefaultClient(defaultClient)
+	defaultClient := &http.Client{
+		Transport: http.DefaultTransport,
+		Timeout:   time.Second * 3,
+	}
 	if timeout, err := v.GetString("request", "timeout"); err == nil && timeout != "" {
 		duration, err := time.ParseDuration(timeout)
 		if err != nil {
@@ -212,11 +210,6 @@ func (h *provider) getTransport(ctx monitorContext.Context, v *value.Value) (htt
 	return tr, nil
 }
 
-func initDefaultClient(c *http.Client) {
-	c.Transport = http.DefaultTransport
-	c.Timeout = time.Second * 3
-}
-
 func parseHeaders(obj cue.Value, label string) (http.Header, error) {
 	m := obj.LookupPath(value.FieldPath("request", label))
 	if !m.Exists() {