aws

Documentation

Index

• Constants
• func DefaultCredentialSecret() types.NamespacedName
• func EscapeJSONPatchString(input string) string
• func FetchAWSCluster(m *Mutator, meta metav1.Object) (*infrastructurev1alpha2.AWSCluster, error)
• func FetchCluster(m *Mutator, meta metav1.Object) (*capiv1alpha2.Cluster, error)
• func FetchRelease(m *Mutator, version *semver.Version) (*releasev1alpha1.Release, error)
• func GetNavailabilityZones(m *Mutator, n int, azs []string) []string
• func GetReleaseComponentLabels(release releasev1alpha1.Release) map[string]string
• func IsHAVersion(releaseVersion *semver.Version) bool
• func IsInvalidConfig(err error) bool
• func IsNotFound(err error) bool
• func IsParsingFailed(err error) bool
• func IsValidMasterReplicas(replicas int) bool
• func MaxBatchSizeIsValid(value string) bool
• func MutateLabelFromAWSCluster(m *Mutator, meta metav1.Object, awsCluster infrastructurev1alpha2.AWSCluster, ...) ([]mutator.PatchOperation, error)
• func MutateLabelFromCluster(m *Mutator, meta metav1.Object, cluster capiv1alpha2.Cluster, label string) ([]mutator.PatchOperation, error)
• func MutateLabelFromRelease(m *Mutator, meta metav1.Object, release releasev1alpha1.Release, label string, ...) ([]mutator.PatchOperation, error)
• func PauseTimeIsValid(value string) bool
• func ReleaseVersion(meta metav1.Object, patch []mutator.PatchOperation) (*semver.Version, error)
• func ValidMasterReplicas() []int
• type Mutator

Constants

const (
	// DefaultClusterDescription is the default name for a cluster
	DefaultClusterDescription = "Unnamed cluster"

	// DefaultMasterReplicas is the default number of master node replicas
	DefaultMasterReplicas = 3

	// DefaultMasterInstanceType is the default master instance type
	DefaultMasterInstanceType = "m5.xlarge"

	// FirstHARelease is the first GS release for AWS that supports HA Masters
	FirstHARelease = "11.4.0"
)

const (
	// annotations should  taken from https://github.com/giantswarm/apiextensions/blob/master/pkg/annotation/aws.go
	// once the service is migrate to apiextensions v3
	AnnotationUpdateMaxBatchSize = "alpha.aws.giantswarm.io/update-max-batch-size"
	AnnotationUpdatePauseTime    = "alpha.aws.giantswarm.io/update-pause-time"
)

Functions

func DefaultCredentialSecret

func DefaultCredentialSecret() types.NamespacedName

DefaultCredentialSecret returns the default credentials for clusters

func EscapeJSONPatchString

func EscapeJSONPatchString(input string) string

Ensure the needed escapes are in place. See https://tools.ietf.org/html/rfc6901#section-3 .

func FetchAWSCluster

func FetchAWSCluster(m *Mutator, meta metav1.Object) (*infrastructurev1alpha2.AWSCluster, error)

func FetchCluster

func FetchCluster(m *Mutator, meta metav1.Object) (*capiv1alpha2.Cluster, error)

func FetchRelease

func FetchRelease(m *Mutator, version *semver.Version) (*releasev1alpha1.Release, error)

func GetNavailabilityZones

func GetNavailabilityZones(m *Mutator, n int, azs []string) []string

func GetReleaseComponentLabels

func GetReleaseComponentLabels(release releasev1alpha1.Release) map[string]string

func IsHAVersion

func IsHAVersion(releaseVersion *semver.Version) bool

IsHAVersion returns whether a given releaseVersion supports HA Masters

func IsInvalidConfig

func IsInvalidConfig(err error) bool

IsInvalidConfig asserts invalidConfigError.

func IsNotFound

func IsNotFound(err error) bool

IsNotFound asserts notFoundError.

func IsParsingFailed

func IsParsingFailed(err error) bool

IsParsingFailed asserts parsingFailedError.

func IsValidMasterReplicas

func IsValidMasterReplicas(replicas int) bool

IsValidMasterReplicas returns whether a given number is a valid number of Master node replicas

func MaxBatchSizeIsValid

func MaxBatchSizeIsValid(value string) bool

MaxBatchSizeIsValid will validate the value into valid maxBatchSize valid values can be either: an integer bigger than 0 a float between 0 < x <= 1 float value is used as ratio of a total worker count

func MutateLabelFromAWSCluster

func MutateLabelFromAWSCluster(m *Mutator, meta metav1.Object, awsCluster infrastructurev1alpha2.AWSCluster, label string) ([]mutator.PatchOperation, error)

func MutateLabelFromCluster

func MutateLabelFromCluster(m *Mutator, meta metav1.Object, cluster capiv1alpha2.Cluster, label string) ([]mutator.PatchOperation, error)

func MutateLabelFromRelease

func MutateLabelFromRelease(m *Mutator, meta metav1.Object, release releasev1alpha1.Release, label string, component string) ([]mutator.PatchOperation, error)

func PauseTimeIsValid

func PauseTimeIsValid(value string) bool

PauseTimeIsValid checks if the value is in proper ISO 8601 duration format and ensure the duration is not bigger than 1 Hour (AWS limitation)

func ReleaseVersion

func ReleaseVersion(meta metav1.Object, patch []mutator.PatchOperation) (*semver.Version, error)

func ValidMasterReplicas

func ValidMasterReplicas() []int

ValidMasterReplicas are the allowed number of master node replicas

Types

type Mutator

type Mutator struct {
	K8sClient k8sclient.Interface
	Logger    micrologger.Logger
}