internal

type AwsClient interface {
	Region() string

	ListS3BucketObjects(ctx context.Context, bucket string, prefix string) ([]s3Types.Object, error)
	HeadS3Bucket(ctx context.Context, bucket string) error
	CreateS3Bucket(ctx context.Context, bucket string, region string) error
	EnableS3BucketVersioning(ctx context.Context, bucket string) error
	MakeS3BucketAclPrivate(ctx context.Context, bucket string) error
	DisableS3BucketPublicAccess(ctx context.Context, bucket string) error
	DeleteS3BucketObject(ctx context.Context, bucket string, key string) error
	PutS3BucketObjectAsBinaryFile(ctx context.Context, bucket string, key string, file *os.File) error
	PutS3BucketObjectAsTextFile(ctx context.Context, bucket string, key string, value string) error
	GetS3BucketObject(ctx context.Context, bucket string, key string) (*s3.GetObjectOutput, error)

	GetALBListenerRule(ctx context.Context, listenerRuleArn string) (*albTypes.Rule, error)
	ModifyALBListenerRule(ctx context.Context, listenerRuleArn string, forwardAction *albTypes.ForwardActionConfig) error
	DescribeALBTargetHealth(ctx context.Context, targetGroupArn string) ([]albTypes.TargetHealthDescription, error)
	DescribeALBTargetGroup(ctx context.Context, targetGroupArn string) (*albTypes.TargetGroup, error)

	DescribeAutoScalingGroup(ctx context.Context, name string) (*asgTypes.AutoScalingGroup, error)
	UpdateAutoScalingGroup(ctx context.Context, name string, desiredCapacity *int32, minSize *int32, maxSize *int32) error
	DescribeScheduledActions(ctx context.Context, name string) ([]asgTypes.ScheduledUpdateGroupAction, error)
	PutScheduledUpdateGroupAction(ctx context.Context, name string, action *asgTypes.ScheduledUpdateGroupAction) error
	DeleteScheduledAction(ctx context.Context, autoScalingGroupName string, scheduledActionName string) error
	GetSSMParameter(ctx context.Context, name string, withDecription bool) (*ssmTypes.Parameter, error)
}

type BundleInfo struct {
	Value        string
	LastModified *time.Time
}

type Bundler struct {
	// contains filtered or unexported fields
}

type Config struct {
	BundleBucket    string       `json:"bundleBucket" validate:"required"`
	ListenerRuleArn string       `json:"listenerRuleArn" validate:"required"`
	Target          *TargetSet   `json:"target" validate:"required"`
	RetryPolicy     *RetryPolicy `json:"retryPolicy" validate:"required"`
	TimeZone        *TimeZone    `json:"timeZone" validate:"required"`
}

type DefaultAwsClient struct {
	// contains filtered or unexported fields
}

type DefaultLogger struct {
	Verbose bool
}

type DeployInfo struct {
	IdlingTarget  *DeployTarget
	RunningTarget *DeployTarget
}

type DeployTarget struct {
	Type             TargetType
	TargetGroup      *albTypes.TargetGroupTuple
	AutoScalingGroup *asgTypes.AutoScalingGroup
}

type Deployer struct {
	// contains filtered or unexported fields
}

type FixedIntervalRetryer struct {
	// contains filtered or unexported fields
}

type HealthInfo struct {
	TargetGroupArn string
	TotalCount     int
	HealthyCount   int
	UnhealthyCount int
	UnusedCount    int
	InitialCount   int
	DrainingCount  int
}

type Logger interface {
	Debug(message string)
	Info(message string)
	Warn(message string, error error)
	Error(message string, error error)
	Fatal(message string, error error)
}

type RetryPolicy struct {
	MaxLimit        int `json:"maxLimit"`
	IntervalSeconds int `json:"intervalSeconds"`
}

type RetryResult bool

type Retryer interface {
	Start(hendler func(index int, interval *time.Duration) (RetryResult, error)) error
}

type Target struct {
	AutoScalingGroupName string `json:"autoScalingGroupName" validate:"required"`
	TargetGroupArn       string `json:"TargetGroupArn" validate:"required"`
}

type TargetSet struct {
	Blue  *Target `json:"blue" validate:"required"`
	Green *Target `json:"green" validate:"required"`
}

type TargetType string

type TimeZone struct {
	Location string `json:"location"`
	Offset   int    `json:"offset"`
}