Merge pull request #3 from ovvesley/nfs-server

created nfs server

Author: ovvesley

cmd/server/main.go

@@ -4,9 +4,9 @@ import (
 	"github.com/ovvesley/akoflow/pkg/server/config"
 	"github.com/ovvesley/akoflow/pkg/server/engine/garbagecollector"
 	"github.com/ovvesley/akoflow/pkg/server/engine/monitor"
+	"github.com/ovvesley/akoflow/pkg/server/engine/orchestrator"
+	"github.com/ovvesley/akoflow/pkg/server/engine/worker"
 )
-import "github.com/ovvesley/akoflow/pkg/server/engine/worker"
-import "github.com/ovvesley/akoflow/pkg/server/engine/orchestrator"
 import "github.com/ovvesley/akoflow/pkg/server/engine/httpserver"
 
 func main() {

pkg/server/entities/workflow_activity_entity/workflow_activity_entity.go

@@ -32,9 +32,9 @@ type WorkflowActivityDatabase struct {
 	ResourceK8sBase64 string
 	Status            int
 	DependOnActivity  *int
-	CreatedAt         string
-	StartedAt         string
-	FinishedAt        string
+	CreatedAt         *string
+	StartedAt         *string
+	FinishedAt        *string
 }
 
 type WorkflowActivityDependencyDatabase struct {
@@ -121,6 +121,21 @@ func DatabaseToWorkflowActivities(params ParamsDatabaseToWorkflowActivities) Wor
 		return WorkflowActivities{}
 	}
 
+	createdAt := ""
+	if params.WorkflowActivityDatabase.CreatedAt != nil {
+		createdAt = *params.WorkflowActivityDatabase.CreatedAt
+	}
+
+	startedAt := ""
+	if params.WorkflowActivityDatabase.StartedAt != nil {
+		startedAt = *params.WorkflowActivityDatabase.StartedAt
+	}
+
+	finishedAt := ""
+	if params.WorkflowActivityDatabase.FinishedAt != nil {
+		finishedAt = *params.WorkflowActivityDatabase.FinishedAt
+	}
+
 	return WorkflowActivities{
 		Id:           params.WorkflowActivityDatabase.Id,
 		Name:         params.WorkflowActivityDatabase.Name,
@@ -132,8 +147,8 @@ func DatabaseToWorkflowActivities(params ParamsDatabaseToWorkflowActivities) Wor
 		DependsOn:    wfa.DependsOn,
 		NodeSelector: wfa.NodeSelector,
 		KeepDisk:     wfa.KeepDisk,
-		CreatedAt:    params.WorkflowActivityDatabase.CreatedAt,
-		StartedAt:    params.WorkflowActivityDatabase.StartedAt,
-		FinishedAt:   params.WorkflowActivityDatabase.FinishedAt,
+		CreatedAt:    createdAt,
+		StartedAt:    startedAt,
+		FinishedAt:   finishedAt,
 	}
 }

pkg/server/services/create_nfs_service/create_nfs_service.go

@@ -356,7 +356,6 @@ func (c *CreateNfsService) Create() bool {
 	resultServiceAccount := conn.ServiceAccount().CreateServiceAccount(serviceAccount)
 	if !resultServiceAccount.Success {
 		log.Printf("Failed to create ServiceAccount: %s", resultServiceAccount.Message)
-		return false
 
 	}
 	fmt.Println(resultServiceAccount.Message)
@@ -366,7 +365,7 @@ func (c *CreateNfsService) Create() bool {
 	resultService := conn.Service().CreateService(service)
 	if !resultService.Success {
 		log.Printf("Failed to create Service: %s", resultService.Message)
-		return false
+
 	}
 	fmt.Println(resultService.Message)
 
@@ -375,7 +374,6 @@ func (c *CreateNfsService) Create() bool {
 	resultPvc := conn.PersistentVolumeClain().CreatePvc(pvc)
 	if !resultPvc.Success {
 		log.Printf("Failed to create PersistentVolumeClaim: %s", resultPvc.Message)
-		return false
 
 	}
 	fmt.Println(resultPvc.Message)
@@ -385,7 +383,6 @@ func (c *CreateNfsService) Create() bool {
 	resultDeployment := conn.Deployment().CreateDeployment(deployment)
 	if !resultDeployment.Success {
 		log.Printf("Failed to create Deployment: %s", resultDeployment.Message)
-		return false
 
 	}
 	fmt.Println(resultDeployment.Message)
@@ -395,7 +392,6 @@ func (c *CreateNfsService) Create() bool {
 	resultClusterRole := conn.ClusterRole().CreateClusterRole(clusterRole)
 	if !resultClusterRole.Success {
 		log.Printf("Failed to create ClusterRole: %s", resultClusterRole.Message)
-		return false
 
 	}
 	fmt.Println(resultClusterRole.Message)
@@ -404,7 +400,7 @@ func (c *CreateNfsService) Create() bool {
 	clusterRoleBinding := c.createClusterRoleBinding()
 	resultClusterRoleBinding := conn.ClusterRoleBinding().CreateClusterRoleBinding(clusterRoleBinding)
 	if !resultClusterRoleBinding.Success {
-		log.Fatalf("Failed to create ClusterRoleBinding: %s", resultClusterRoleBinding.Message)
+		log.Printf("Failed to create ClusterRoleBinding: %s", resultClusterRoleBinding.Message)
 	}
 	fmt.Println(resultClusterRoleBinding.Message)
 
@@ -413,7 +409,6 @@ func (c *CreateNfsService) Create() bool {
 	resultRole := conn.Role().CreateRole(role)
 	if !resultRole.Success {
 		log.Printf("Failed to create Role: %s", resultRole.Message)
-		return false
 
 	}
 	fmt.Println(resultRole.Message)
@@ -423,7 +418,6 @@ func (c *CreateNfsService) Create() bool {
 	resultRoleBinding := conn.RoleBinding().CreateRoleBinding(roleBinding)
 	if !resultRoleBinding.Success {
 		log.Printf("Failed to create RoleBinding: %s", resultRoleBinding.Message)
-		return false
 
 	}
 	fmt.Println(resultRoleBinding.Message)
@@ -433,7 +427,6 @@ func (c *CreateNfsService) Create() bool {
 	resultStorageClass := conn.StorageClass().CreateStorageClass(storageClass)
 	if !resultStorageClass.Success {
 		log.Printf("Failed to create StorageClass: %s", resultStorageClass.Message)
-		return false
 	}
 	fmt.Println(resultStorageClass.Message)