Refactoring: Support of different deployments kind

internal/app/upgradeagent/dockercomposedeployment.go

@@ -0,0 +1,36 @@
+package upgradeagent
+
+type dockerComposeDeployment struct {
+	upgradeInfo    *UpstreamResponseUpgradeInfo
+	upstreamClient UpstreamClient
+}
+
+// NewDockerComposeDeployment creates a new instance of docker-compose deployment kind.
+func NewDockerComposeDeployment(upstreamServiceClient UpstreamClient) DeploymentClient {
+	return &dockerComposeDeployment{upgradeInfo: NewUpstreamResponseUpgradeInfo(), upstreamClient: upstreamServiceClient}
+}
+
+// UpgradeCheck do check if there is a new version of the current solution available
+func (d *dockerComposeDeployment) UpgradeCheck(localSolutionInfo LocalSolutionInfo) bool {
+	if upgradeInfo, isNewVersion := d.upstreamClient.RequestUpgrade(localSolutionInfo); isNewVersion {
+		d.upgradeInfo = upgradeInfo
+		return true
+	}
+	return false
+}
+
+// Upgrade does upgrade the current solution
+func (d *dockerComposeDeployment) Upgrade() error {
+	return nil
+}
+
+// Rollback does rollback the current solution to the previous state in case both upgrade or health check is fails
+func (d *dockerComposeDeployment) Rollback() {
+	// TBD
+}
+
+// HealthCheck does a health check of the current solution after the upgrade
+func (d *dockerComposeDeployment) HealthCheck() bool {
+	d.upgradeInfo.HealthCheckStatus = Unhealthy
+	return false
+}

internal/app/upgradeagent/kubernetesdeployment.go

@@ -0,0 +1,36 @@
+package upgradeagent
+
+type kubernetesDeployment struct {
+	upgradeInfo    *UpstreamResponseUpgradeInfo
+	upstreamClient UpstreamClient
+}
+
+// NewKubernetesDeployment creates a new instance of kubernetes deployment kind.
+func NewKubernetesDeployment(upstreamServiceClient UpstreamClient) DeploymentClient {
+	return &kubernetesDeployment{upgradeInfo: NewUpstreamResponseUpgradeInfo(), upstreamClient: upstreamServiceClient}
+}
+
+// UpgradeCheck do check if there is a new version of the current solution available
+func (d *kubernetesDeployment) UpgradeCheck(localSolutionInfo LocalSolutionInfo) bool {
+	if upgradeInfo, isNewVersion := d.upstreamClient.RequestUpgrade(localSolutionInfo); isNewVersion {
+		d.upgradeInfo = upgradeInfo
+		return true
+	}
+	return false
+}
+
+// Upgrade does upgrade the current solution
+func (d *kubernetesDeployment) Upgrade() error {
+	return nil
+}
+
+// Rollback does rollback the current solution to the previous state in case both upgrade or health check is fails
+func (d *kubernetesDeployment) Rollback() {
+	// TBD
+}
+
+// HealthCheck does a health check of the current solution after the upgrade
+func (d *kubernetesDeployment) HealthCheck() bool {
+	d.upgradeInfo.HealthCheckStatus = Unhealthy
+	return false
+}

internal/app/upgradeagent/mockupstreamclient.go

@@ -0,0 +1,14 @@
+package upgradeagent
+
+type mockUpstreamClient struct {
+}
+
+// NewMockUpstreamClient returns a new instance of mock upstream service client
+func NewMockUpstreamClient() UpstreamClient {
+	return mockUpstreamClient{}
+}
+
+// RequestUpgrade implements the transport layer between Patrao and mocked upstream service
+func (mock mockUpstreamClient) RequestUpgrade(solutionInfo LocalSolutionInfo) (*UpstreamResponseUpgradeInfo, bool) {
+	return nil, false
+}

internal/app/upgradeagent/objects.go

@@ -4,6 +4,19 @@ import (
 	"time"
 )
 
+// DeploymentClient is a common interface for any deployment kinds.
+type DeploymentClient interface {
+	UpgradeCheck(LocalSolutionInfo) bool
+	Upgrade() error
+	HealthCheck() bool
+	Rollback()
+}
+
+// UpstreamClient is a common interface for any upstream service kinds
+type UpstreamClient interface {
+	RequestUpgrade(LocalSolutionInfo) (*UpstreamResponseUpgradeInfo, bool)
+}
+
 // KindType Kind type for all structures
 type KindType string