feat: added support to deploy global service (#126)

Author: tanmoysrt

container_manager/service.go

@@ -216,6 +216,24 @@ func (m Manager) serviceToServiceSpec(service Service) swarm.ServiceSpec {
 		env = append(env, key+"="+value)
 	}
 
+	var serviceMode swarm.ServiceMode
+
+	if service.DeploymentMode == DeploymentModeReplicated {
+		// allow replicated service
+		serviceMode = swarm.ServiceMode{
+			Replicated: &swarm.ReplicatedService{
+				Replicas: &service.Replicas,
+			},
+		}
+	} else if service.DeploymentMode == DeploymentModeGlobal {
+		// allow global service
+		serviceMode = swarm.ServiceMode{
+			Global: &swarm.GlobalService{},
+		}
+	} else {
+		panic("invalid deployment mode")
+	}
+
 	// Build service spec
 	serviceSpec := swarm.ServiceSpec{
 		// Set name of the service
@@ -235,11 +253,7 @@ func (m Manager) serviceToServiceSpec(service Service) swarm.ServiceSpec {
 			Networks: networkAttachmentConfigs,
 		},
 		// allow replicated service
-		Mode: swarm.ServiceMode{
-			Replicated: &swarm.ReplicatedService{
-				Replicas: &service.Replicas,
-			},
-		},
+		Mode: serviceMode,
 		// constant endpoint
 		EndpointSpec: &swarm.EndpointSpec{
 			Mode: swarm.ResolutionModeDNSRR,

container_manager/types.go

@@ -11,14 +11,22 @@ type Manager struct {
 	client *client.Client
 }
 
+type DeploymentMode string
+
+const (
+	DeploymentModeReplicated DeploymentMode = "replicated"
+	DeploymentModeGlobal     DeploymentMode = "global"
+)
+
 type Service struct {
-	Name         string            `json:"name"`
-	Image        string            `json:"image"`
-	Command      []string          `json:"command,omitempty"`
-	Env          map[string]string `json:"env,omitempty"`
-	VolumeMounts []VolumeMount     `json:"volumemounts,omitempty"`
-	Networks     []string          `json:"networks,omitempty"`
-	Replicas     uint64            `json:"replicas"`
+	Name           string            `json:"name"`
+	Image          string            `json:"image"`
+	Command        []string          `json:"command,omitempty"`
+	Env            map[string]string `json:"env,omitempty"`
+	VolumeMounts   []VolumeMount     `json:"volumemounts,omitempty"`
+	Networks       []string          `json:"networks,omitempty"`
+	DeploymentMode DeploymentMode    `json:"deploymentmode"`
+	Replicas       uint64            `json:"replicas"`
 }
 
 type ServiceRealtimeInfo struct {

swiftwave_service/worker/process_application_deploy_request.go

@@ -121,13 +121,14 @@ func (m Manager) DeployApplication(request DeployApplicationRequest) error {
 	}
 	// create service
 	service := containermanger.Service{
-		Name:         application.Name,
-		Image:        dockerImageUri,
-		Command:      []string{},
-		Env:          environmentVariablesMap,
-		Networks:     []string{m.ServiceConfig.SwarmNetwork},
-		Replicas:     uint64(application.Replicas),
-		VolumeMounts: volumeMounts,
+		Name:           application.Name,
+		Image:          dockerImageUri,
+		Command:        []string{},
+		Env:            environmentVariablesMap,
+		Networks:       []string{m.ServiceConfig.SwarmNetwork},
+		DeploymentMode: containermanger.DeploymentMode(application.DeploymentMode),
+		Replicas:       uint64(application.Replicas),
+		VolumeMounts:   volumeMounts,
 	}
 	// check if the service already exists
 	_, err = m.ServiceManager.DockerManager.GetService(service.Name)