ecspresso/export_test.go at v2 · kayac/ecspresso · GitHub

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
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
package ecspresso

import (
	"context"
	"io"
	"log/slog"
	"time"

	"github.com/aws/aws-sdk-go-v2/config"
	"github.com/aws/aws-sdk-go-v2/service/ecs/types"
)

var (
	SortTaskDefinition     = sortTaskDefinition
	ToNumberCPU            = toNumberCPU
	ToNumberMemory         = toNumberMemory
	CalcDesiredCount       = calcDesiredCount
	ParseTags              = parseTags
	ParseImageURL          = parseImageURL
	ExtractRoleName        = extractRoleName
	IsLongArnFormat        = isLongArnFormat
	ECRImageURLRegex       = ecrImageURLRegex
	NewLogger              = newLogger
	NewConfigLoader        = newConfigLoader
	LogLevel               = logLevel
	SetLogFormat           = setLogFormat
	NewVerifier            = newVerifier
	ArnToName              = arnToName
	NewVerifyState         = newVerifyState
	Map2str                = map2str
	DiffServices           = diffServices
	DiffTaskDefs           = diffTaskDefs
	IsPermissionError      = isPermissionError
	WrapPermissionError    = wrapPermissionError
	ParseIAMPolicyDocument = parseIAMPolicyDocument
	ParseSections          = parseSections
	ReadmeContent          = readmeContent
)

type ModifyAutoScalingParams = modifyAutoScalingParams
type IAMPolicyDocument = iamPolicyDocument
type StringOrSlice = stringOrSlice

func (s StringOrSlice) Contains(v string) bool {
	return s.contains(v)
}

func (d *App) SetLogger(logger *slog.Logger) {
	d.logger = logger
}

func SetLogger(logger *slog.Logger) {
	commonLogger = logger
}

func SetAWSV2ConfigLoadOptionsFunc(f []func(*config.LoadOptions) error) {
	awsv2ConfigLoadOptionsFunc = f
}

func ResetAWSV2ConfigLoadOptionsFunc() {
	awsv2ConfigLoadOptionsFunc = nil
}

type TaskDefinitionForRun = taskDefinitionForRun

func (d *App) ResolveTaskDefinitionForRun(ctx context.Context, opt RunOption) (*taskDefinitionForRun, error) {
	return d.resolveTaskDefinitionForRun(ctx, opt)
}

func (opt *DiffOption) SetWriter(w io.Writer) {
	opt.w = w
}

func (i *ConfigIgnore) FilterTags(tags []types.Tag) []types.Tag {
	return i.filterTags(tags)
}

// SleepContext exposes sleepContext for testing
func SleepContext(ctx context.Context, d time.Duration) {
	sleepContext(ctx, d)
}