🎨 divided into several files because large struct

aws/ecs.go

@@ -29,18 +29,25 @@ func NewECSManager(accessKey string, secretKey string, region string) *ECSManage
 	return manager
 }
 
-func (self *ECSManager) CreateCluster(clusterName string) (*ecs.CreateClusterOutput, error) {
-
-	svc := ecs.New(&aws.Config{
-		Region: self.Region,
+func (self *ECSManager) ClusterApi() *EcsClusterApi {
+	return &EcsClusterApi{
 		Credentials: self.Credentials,
-	})
+		Region: self.Region,
+	}
+}
 
-	params := &ecs.CreateClusterInput{
-		ClusterName: aws.String(clusterName),
+func (self *EcsServiceApi) ServiceApi() *EcsServiceApi {
+	return &EcsServiceApi{
+		Credentials: self.Credentials,
+		Region: self.Region,
 	}
+}
 
-	return svc.CreateCluster(params)
+func (self *EcsServiceApi) TaskApi() *EcsTaskApi {
+	return &EcsTaskApi{
+		Credentials: self.Credentials,
+		Region: self.Region,
+	}
 }
 
 func (self *ECSManager) DescribeTaskDefinition(defName string) (*ecs.DescribeTaskDefinitionOutput, error) {
@@ -145,20 +152,6 @@ func (self *ECSManager) DeregisterTaskDefinition(taskName string) (*ecs.Deregist
 	return svc.DeregisterTaskDefinition(params)
 }
 
-func (self *ECSManager) DescribeClusters(clusterNames []*string) (*ecs.DescribeClustersOutput, error) {
-
-	svc := ecs.New(&aws.Config{
-		Region: self.Region,
-		Credentials: self.Credentials,
-	})
-
-	params := &ecs.DescribeClustersInput{
-		Clusters: clusterNames,
-	}
-
-	return svc.DescribeClusters(params)
-}
-
 func (self *ECSManager) CreateService(cluster string, service schema.Service) (*ecs.CreateServiceOutput, error) {
 
 	svc := ecs.New(&aws.Config{

aws/ecs_cluster_api.go

@@ -0,0 +1,68 @@
+package aws
+
+import (
+	"github.com/aws/aws-sdk-go/aws"
+	"github.com/aws/aws-sdk-go/service/ecs"
+	"github.com/aws/aws-sdk-go/aws/credentials"
+)
+
+type EcsClusterApi struct {
+	Credentials *credentials.Credentials
+	Region      string
+}
+
+func (self *EcsClusterApi) CreateCluster(clusterName string) (*ecs.CreateClusterOutput, error) {
+
+	svc := ecs.New(&aws.Config{
+		Region: self.Region,
+		Credentials: self.Credentials,
+	})
+
+	params := &ecs.CreateClusterInput{
+		ClusterName: aws.String(clusterName),
+	}
+
+	return svc.CreateCluster(params)
+}
+
+func (self *EcsClusterApi) DeleteCluster(clusterName string) (*ecs.DeleteClusterOutput, error) {
+
+	svc := ecs.New(&aws.Config{
+		Region: self.Region,
+		Credentials: self.Credentials,
+	})
+
+	params := &ecs.DeleteClusterInput{
+		Cluster: aws.String(clusterName),
+	}
+
+	return svc.DeleteCluster(params)
+}
+
+func (self *EcsClusterApi) DescribeClusters(clusterNames []*string) (*ecs.DescribeClustersOutput, error) {
+
+	svc := ecs.New(&aws.Config{
+		Region: self.Region,
+		Credentials: self.Credentials,
+	})
+
+	params := &ecs.DescribeClustersInput{
+		Clusters: clusterNames,
+	}
+
+	return svc.DescribeClusters(params)
+}
+
+func (self *EcsClusterApi) ListClusters(maxResult int64) (*ecs.ListClustersOutput, error) {
+
+	svc := ecs.New(&aws.Config{
+		Region: self.Region,
+		Credentials: self.Credentials,
+	})
+
+	params := &ecs.ListClustersInput{
+		MaxResults: aws.Long(maxResult),
+	}
+
+	return svc.ListClusters(params)
+}

aws/ecs_service_api.go

@@ -0,0 +1,10 @@
+package aws
+
+import (
+	"github.com/aws/aws-sdk-go/aws/credentials"
+)
+
+type EcsServiceApi struct {
+	Credentials *credentials.Credentials
+	Region      string
+}

aws/ecs_task_api.go

@@ -0,0 +1,10 @@
+package aws
+
+import (
+	"github.com/aws/aws-sdk-go/aws/credentials"
+)
+
+type EcsTaskApi struct {
+	Credentials *credentials.Credentials
+	Region      string
+}

cluster/cluster.go

@@ -63,7 +63,8 @@ func (self *ClusterControler) CreateClusterUpdatePlans(clusters []schema.Cluster
 }
 
 func (self *ClusterControler) CreateClusterUpdatePlan(cluster schema.Cluster) *plan.ClusterUpdatePlan {
-	output, err := self.Ecs.DescribeClusters([]*string{&cluster.Name})
+
+	output, err := self.Ecs.ClusterApi().DescribeClusters([]*string{&cluster.Name})
 
 	if err != nil {
 		fmt.Fprintln(os.Stderr, color.Red("[ERROR] discribe_cluster"))