elasticache

package
v0.36.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 18, 2023 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ConnectionEndpoint

ConnectionEndpoint returns the connection endpoint for a Replication Group. https://docs.aws.amazon.com/AmazonElastiCache/latest/red-ug/Endpoints.html

func DiffTags

func DiffTags(rgtags []v1beta1.Tag, tags []elasticachetypes.Tag) (add map[string]string, remove []string)

DiffTags returns tags that should be added or removed.

func GenerateCluster

GenerateCluster modifies elasticache.CacheCluster with values from cachev1alpha1.CacheClusterParameters

func GenerateClusterObservation

GenerateClusterObservation produces a CacheClusterObservation object out of received elasticache.CacheCluster object.

func GenerateCreateCacheClusterInput

func GenerateCreateCacheClusterInput(p cachev1alpha1.CacheClusterParameters, id string) *elasticache.CreateCacheClusterInput

GenerateCreateCacheClusterInput returns Cache Cluster creation input

func GenerateModifyCacheClusterInput

func GenerateModifyCacheClusterInput(p cachev1alpha1.CacheClusterParameters, id string) *elasticache.ModifyCacheClusterInput

GenerateModifyCacheClusterInput returns ElastiCache Cache Cluster modification input suitable for use with the AWS API.

func GenerateObservation

GenerateObservation produces a ReplicationGroupObservation object out of received elasticache.ReplicationGroup object.

func IsAlreadyExists

func IsAlreadyExists(err error) bool

IsAlreadyExists returns true if the supplied error indicates a Replication Group already exists.

func IsClusterNotFound

func IsClusterNotFound(err error) bool

IsClusterNotFound returns true if the supplied error indicates a Cache Cluster already exists.

func IsClusterUpToDate

func IsClusterUpToDate(name string, in *cachev1alpha1.CacheClusterParameters, observed *elasticachetypes.CacheCluster) (bool, error)

IsClusterUpToDate checks whether current state is up-to-date compared to the given set of parameters.

func IsNotFound

func IsNotFound(err error) bool

IsNotFound returns true if the supplied error indicates a Replication Group was not found.

func IsSubnetGroupNotFound

func IsSubnetGroupNotFound(err error) bool

IsSubnetGroupNotFound returns true if the supplied error indicates a Cache Subnet Group was not found.

func IsSubnetGroupUpToDate

IsSubnetGroupUpToDate checks if CacheSubnetGroupParameters are in sync with provider values

func LateInitialize

LateInitialize assigns the observed configurations and assigns them to the corresponding fields in ReplicationGroupParameters in order to let user know the defaults and make the changes as wished on that value.

func LateInitializeCluster

LateInitializeCluster assigns the observed configurations and assigns them to the corresponding fields in CacheClusterParameters in order to let user know the defaults and make the changes as wished on that value.

func NewCreateReplicationGroupInput

func NewCreateReplicationGroupInput(g v1beta1.ReplicationGroupParameters, id string, authToken *string) *elasticache.CreateReplicationGroupInput

NewCreateReplicationGroupInput returns ElastiCache replication group creation input suitable for use with the AWS API.

func NewDecreaseReplicaCountInput

func NewDecreaseReplicaCountInput(replicationGroupID string, newReplicaCount *int32) *elasticache.DecreaseReplicaCountInput

NewDecreaseReplicaCountInput returns Elasticache replication group decrease the number of replicaGroup cache clusters

func NewDeleteReplicationGroupInput

func NewDeleteReplicationGroupInput(id string) *elasticache.DeleteReplicationGroupInput

NewDeleteReplicationGroupInput returns ElastiCache replication group deletion input suitable for use with the AWS API.

func NewDescribeCacheClustersInput

func NewDescribeCacheClustersInput(clusterID string) *elasticache.DescribeCacheClustersInput

NewDescribeCacheClustersInput returns ElastiCache cache cluster describe input suitable for use with the AWS API.

func NewDescribeReplicationGroupsInput

func NewDescribeReplicationGroupsInput(id string) *elasticache.DescribeReplicationGroupsInput

NewDescribeReplicationGroupsInput returns ElastiCache replication group describe input suitable for use with the AWS API.

func NewIncreaseReplicaCountInput

func NewIncreaseReplicaCountInput(replicationGroupID string, newReplicaCount *int32) *elasticache.IncreaseReplicaCountInput

NewIncreaseReplicaCountInput returns Elasticache replication group increase the number of replicaGroup cache clusters

func NewListTagsForResourceInput

func NewListTagsForResourceInput(arn *string) *elasticache.ListTagsForResourceInput

NewListTagsForResourceInput returns ElastiCache list tags input usable with the AWS API

func NewModifyReplicationGroupInput

NewModifyReplicationGroupInput returns ElastiCache replication group modification input suitable for use with the AWS API.

func NewModifyReplicationGroupShardConfigurationInput

NewModifyReplicationGroupShardConfigurationInput returns ElastiCache replication group shard configuration modification input suitable for use with the AWS API.

func ReplicationGroupNeedsUpdate

ReplicationGroupNeedsUpdate returns true if the supplied ReplicationGroup and the configuration of its member clusters differ from given desired state.

func ReplicationGroupNumCacheClustersNeedsUpdate

func ReplicationGroupNumCacheClustersNeedsUpdate(kube v1beta1.ReplicationGroupParameters, ccList []elasticachetypes.CacheCluster) bool

ReplicationGroupNumCacheClustersNeedsUpdate determines if the number of Cache Clusters in a replication group needs to be updated

func ReplicationGroupShardConfigurationNeedsUpdate

func ReplicationGroupShardConfigurationNeedsUpdate(kube v1beta1.ReplicationGroupParameters, rg elasticachetypes.ReplicationGroup) bool

ReplicationGroupShardConfigurationNeedsUpdate returns true if the supplied ReplicationGroup and the configuration shards.

func ReplicationGroupTagsNeedsUpdate

func ReplicationGroupTagsNeedsUpdate(kube []v1beta1.Tag, tags []elasticachetypes.Tag) bool

ReplicationGroupTagsNeedsUpdate indicates whether tags need updating

Types

type Client

type Client interface {
	DescribeReplicationGroups(context.Context, *elasticache.DescribeReplicationGroupsInput, ...func(*elasticache.Options)) (*elasticache.DescribeReplicationGroupsOutput, error)
	CreateReplicationGroup(context.Context, *elasticache.CreateReplicationGroupInput, ...func(*elasticache.Options)) (*elasticache.CreateReplicationGroupOutput, error)
	ModifyReplicationGroup(context.Context, *elasticache.ModifyReplicationGroupInput, ...func(*elasticache.Options)) (*elasticache.ModifyReplicationGroupOutput, error)
	DeleteReplicationGroup(context.Context, *elasticache.DeleteReplicationGroupInput, ...func(*elasticache.Options)) (*elasticache.DeleteReplicationGroupOutput, error)

	DescribeCacheSubnetGroups(context.Context, *elasticache.DescribeCacheSubnetGroupsInput, ...func(*elasticache.Options)) (*elasticache.DescribeCacheSubnetGroupsOutput, error)
	CreateCacheSubnetGroup(context.Context, *elasticache.CreateCacheSubnetGroupInput, ...func(*elasticache.Options)) (*elasticache.CreateCacheSubnetGroupOutput, error)
	ModifyCacheSubnetGroup(context.Context, *elasticache.ModifyCacheSubnetGroupInput, ...func(*elasticache.Options)) (*elasticache.ModifyCacheSubnetGroupOutput, error)
	DeleteCacheSubnetGroup(context.Context, *elasticache.DeleteCacheSubnetGroupInput, ...func(*elasticache.Options)) (*elasticache.DeleteCacheSubnetGroupOutput, error)

	DescribeCacheClusters(context.Context, *elasticache.DescribeCacheClustersInput, ...func(*elasticache.Options)) (*elasticache.DescribeCacheClustersOutput, error)
	CreateCacheCluster(context.Context, *elasticache.CreateCacheClusterInput, ...func(*elasticache.Options)) (*elasticache.CreateCacheClusterOutput, error)
	DeleteCacheCluster(context.Context, *elasticache.DeleteCacheClusterInput, ...func(*elasticache.Options)) (*elasticache.DeleteCacheClusterOutput, error)
	ModifyCacheCluster(context.Context, *elasticache.ModifyCacheClusterInput, ...func(*elasticache.Options)) (*elasticache.ModifyCacheClusterOutput, error)

	DecreaseReplicaCount(ctx context.Context, params *elasticache.DecreaseReplicaCountInput, optFns ...func(*elasticache.Options)) (*elasticache.DecreaseReplicaCountOutput, error)
	IncreaseReplicaCount(ctx context.Context, params *elasticache.IncreaseReplicaCountInput, optFns ...func(*elasticache.Options)) (*elasticache.IncreaseReplicaCountOutput, error)

	ModifyReplicationGroupShardConfiguration(context.Context, *elasticache.ModifyReplicationGroupShardConfigurationInput, ...func(*elasticache.Options)) (*elasticache.ModifyReplicationGroupShardConfigurationOutput, error)

	ListTagsForResource(context.Context, *elasticache.ListTagsForResourceInput, ...func(*elasticache.Options)) (*elasticache.ListTagsForResourceOutput, error)
	AddTagsToResource(context.Context, *elasticache.AddTagsToResourceInput, ...func(*elasticache.Options)) (*elasticache.AddTagsToResourceOutput, error)
	RemoveTagsFromResource(context.Context, *elasticache.RemoveTagsFromResourceInput, ...func(*elasticache.Options)) (*elasticache.RemoveTagsFromResourceOutput, error)
}

A Client handles CRUD operations for ElastiCache resources.

func NewClient

func NewClient(cfg aws.Config) Client

NewClient returns a new ElastiCache client. Credentials must be passed as JSON encoded data.

type PartialSemanticVersion added in v0.29.0

type PartialSemanticVersion struct {
	Major *int64
	Minor *int64
	Patch *int64
}

PartialSemanticVersion is semantic version that does not fulfill the specification. This allows for partial matching.

func ParseVersion added in v0.29.0

func ParseVersion(ver *string) (*PartialSemanticVersion, error)

ParseVersion parses the semantic version of an Elasticache Cluster See https://docs.aws.amazon.com/memorydb/latest/devguide/engine-versions.html

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL