Skip to content

Commit 378ccab

Browse files
Update opensearchservice-vpcendpoints.go
Correctly retrieving VPC endpoint ids.
1 parent 84fbd14 commit 378ccab

File tree

1 file changed

+21
-1
lines changed

1 file changed

+21
-1
lines changed

resources/opensearchservice-vpcendpoints.go

Lines changed: 21 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,8 +18,13 @@ func init() {
1818
func ListOSVPCEndpoints(sess *session.Session) ([]Resource, error) {
1919
svc := opensearchservice.New(sess)
2020

21+
vpcEndpointIds, err := getOpenSearchVpcEndpointIds(svc)
22+
if err != nil {
23+
return nil, err
24+
}
25+
2126
listResp, err := svc.DescribeVpcEndpoints(&opensearchservice.DescribeVpcEndpointsInput{
22-
VpcEndpointIds: []*string{},
27+
VpcEndpointIds: vpcEndpointIds,
2328
})
2429
if err != nil {
2530
return nil, err
@@ -37,6 +42,21 @@ func ListOSVPCEndpoints(sess *session.Session) ([]Resource, error) {
3742
return resources, nil
3843
}
3944

45+
func getOpenSearchVpcEndpointIds(svc *opensearchservice.OpenSearchService) ([]*string, error) {
46+
vpcEndpointIds := make([]*string, 0)
47+
48+
listResp, err := svc.ListVpcEndpoints(&opensearchservice.ListVpcEndpointsInput{})
49+
if err != nil {
50+
return nil, err
51+
}
52+
53+
for _, vpcEndpoint := range listResp.VpcEndpointSummaryList {
54+
vpcEndpointIds = append(vpcEndpointIds, vpcEndpoint.VpcEndpointId)
55+
}
56+
57+
return vpcEndpointIds, nil
58+
}
59+
4060
func (o *OSVPCEndpoint) Remove() error {
4161
_, err := o.svc.DeleteVpcEndpoint(&opensearchservice.DeleteVpcEndpointInput{
4262
VpcEndpointId: o.vpcEndpointId,

0 commit comments

Comments
 (0)