describe es domain with sdk v2

Financial-Times · Nov 3, 2022 · 79f7a96 · 79f7a96
1 parent e82faf6
commit 79f7a96
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 0 deletions.
diff --git a/cmd/content-rw-elasticsearch/main.go b/cmd/content-rw-elasticsearch/main.go
@@ -16,6 +16,7 @@ import (
 	"github.com/Financial-Times/go-logger/v2"
 	"github.com/Financial-Times/kafka-client-go/v3"
 	kafka2config "github.com/aws/aws-sdk-go-v2/config"
+	"github.com/aws/aws-sdk-go-v2/service/elasticsearchservice"
 	kafka2 "github.com/aws/aws-sdk-go-v2/service/kafka"
 	"github.com/aws/aws-sdk-go/aws"
 	"github.com/aws/aws-sdk-go/aws/credentials"
@@ -178,6 +179,16 @@ func main() {
 			} else {
 				log.WithField("state", cluster.ClusterInfo.State).Info("Cluster successfully described v1 using v2 client")
 			}
+
+			esSvc := elasticsearchservice.NewFromConfig(cfg)
+			domain, err := esSvc.DescribeElasticsearchDomain(ctx, &elasticsearchservice.DescribeElasticsearchDomainInput{
+				DomainName: aws.String("upp-sapi-v2-dev-eu"),
+			})
+			if err != nil {
+				log.WithError(err).Error("Failed to describe ES domain using v2 client")
+			} else {
+				log.WithField("arn", domain.DomainStatus.ARN).Info("Domain successfully described using v2 client")
+			}
 		}
 
 		httpClient := pkghttp.NewHTTPClient()

diff --git a/go.mod b/go.mod
@@ -10,6 +10,7 @@ require (
 	github.com/Financial-Times/transactionid-utils-go v0.2.0
 	github.com/aws/aws-sdk-go v1.44.128
 	github.com/aws/aws-sdk-go-v2/config v1.17.10
+	github.com/aws/aws-sdk-go-v2/service/elasticsearchservice v1.16.12
 	github.com/aws/aws-sdk-go-v2/service/kafka v1.18.0
 	github.com/gorilla/mux v1.8.0
 	github.com/jawher/mow.cli v1.0.4

diff --git a/go.sum b/go.sum
@@ -81,6 +81,8 @@ github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.4.19 h1:oRHDrwCTVT8ZXi4sr9
 github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.4.19/go.mod h1:6Q0546uHDp421okhmmGfbxzq2hBqbXFNpi4k+Q1JnQA=
 github.com/aws/aws-sdk-go-v2/internal/ini v1.3.26 h1:Mza+vlnZr+fPKFKRq/lKGVvM6B/8ZZmNdEopOwSQLms=
 github.com/aws/aws-sdk-go-v2/internal/ini v1.3.26/go.mod h1:Y2OJ+P+MC1u1VKnavT+PshiEuGPyh/7DqxoDNij4/bg=
+github.com/aws/aws-sdk-go-v2/service/elasticsearchservice v1.16.12 h1:jQugOx7b1FnjZL4HzNMroh7ulj0oN5Pp8akS8UvRh1A=
+github.com/aws/aws-sdk-go-v2/service/elasticsearchservice v1.16.12/go.mod h1:UY0dc/ngkmYkBegXTwQ3kILLtItU8UJuueHHD91vn88=
 github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.9.19 h1:GE25AWCdNUPh9AOJzI9KIJnja7IwUc1WyUqz/JTyJ/I=
 github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.9.19/go.mod h1:02CP6iuYP+IVnBX5HULVdSAku/85eHB2Y9EsFhrkEwU=
 github.com/aws/aws-sdk-go-v2/service/kafka v1.18.0 h1:Qm5FG103xKYe3Hi4aEeoTv3XY3MqklQezovzAt+H3gU=