/
parameter.go
61 lines (52 loc) · 1.63 KB
/
parameter.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
package platform_aws_ecs
import (
"context"
"github.com/awlsring/texit/internal/pkg/domain/node"
"github.com/awlsring/texit/internal/pkg/interfaces"
"github.com/awlsring/texit/internal/pkg/logger"
"github.com/aws/aws-sdk-go-v2/aws"
"github.com/aws/aws-sdk-go-v2/service/ssm"
"github.com/aws/aws-sdk-go-v2/service/ssm/types"
)
func makeStateParameter(ctx context.Context, client interfaces.SsmClient, id node.Identifier) (string, error) {
log := logger.FromContext(ctx)
log.Debug().Msg("Creating state parameter")
_, err := client.PutParameter(ctx, &ssm.PutParameterInput{
Name: aws.String(id.String()),
Type: types.ParameterTypeString,
Value: aws.String("{}"),
Tags: []types.Tag{
{
Key: aws.String("created-by"),
Value: aws.String("texit"),
},
},
})
if err != nil {
log.Error().Err(err).Msg("Failed to create state parameter")
return "", err
}
log.Debug().Msg("State parameter created")
log.Debug().Msg("Describe state parameter to get arn")
resp, err := client.GetParameter(ctx, &ssm.GetParameterInput{
Name: aws.String(id.String()),
})
if err != nil {
log.Error().Err(err).Msg("Failed to describe state parameter")
return "", err
}
return *resp.Parameter.ARN, nil
}
func deleteStateParameter(ctx context.Context, client interfaces.SsmClient, id node.Identifier) error {
log := logger.FromContext(ctx)
log.Debug().Msg("Deleting state parameter")
_, err := client.DeleteParameter(ctx, &ssm.DeleteParameterInput{
Name: aws.String(id.String()),
})
if err != nil {
log.Error().Err(err).Msg("Failed to delete state parameter")
return err
}
log.Debug().Msg("State parameter deleted")
return nil
}