refactor(pkg-nexus): elastic deployer

Move running and paused status to deployer models since it can be reused for kuberclient.
valentin-carl · Jan 25, 2024 · 94180ed · 94180ed
1 parent 5fdc7b5
commit 94180ed
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 9 deletions.
diff --git a/pkg/nexus/elastic-deploy/docker/docker-deployer.go b/pkg/nexus/elastic-deploy/docker/docker-deployer.go
@@ -8,11 +8,6 @@ import (
 	"time"
 )
 
-const (
-	running = "running"
-	paused  = "paused"
-)
-
 type DockerDeployer struct {
 	*deployer_models.ProElasticDeployerConfig
 	*docker.Client
@@ -73,7 +68,7 @@ func (ds *DockerDeployer) Unpause(functionName string) error {
 	}
 
 	fmt.Println("Container state: ", container.State)
-	if container.State == paused {
+	if container.State == deployer_models.Paused {
 		err := ds.UnpauseContainer(container.ID)
 		if err != nil {
 			return err
@@ -90,12 +85,12 @@ func (ds *DockerDeployer) Unpause(functionName string) error {
 
 func (ds *DockerDeployer) Pause(functionName string) error {
 	container := ds.getFunctionContainer(functionName)
-	if container.State == paused {
+	if container.State == deployer_models.Paused {
 		fmt.Printf("Container %s has been paused already\n", ds.getContainerName(functionName))
 		return nil
 	}
 
-	if container.State == running {
+	if container.State == deployer_models.Running {
 		err := ds.PauseContainer(container.ID)
 		if err != nil {
 			return err
@@ -110,7 +105,7 @@ func (ds *DockerDeployer) Pause(functionName string) error {
 
 func (ds *DockerDeployer) IsRunning(functionName string) bool {
 	container := ds.getFunctionContainer(functionName)
-	return container.State == running
+	return container.State == deployer_models.Running
 }
 
 func (ds *DockerDeployer) getFunctionContainer(functionName string) *docker.APIContainers {

diff --git a/pkg/nexus/elastic-deploy/models/pro-elastic-deployer-structs.go b/pkg/nexus/elastic-deploy/models/pro-elastic-deployer-structs.go
@@ -4,6 +4,11 @@ import (
 	"time"
 )
 
+const (
+	Running = "Running"
+	Paused  = "Paused"
+)
+
 type ElasticDeployer interface {
 	Unpause(functionName string) error
 	Pause(functionName string) error