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 

func ConnectionEndpoint(rg elasticachetypes.ReplicationGroup) managed.ConnectionDetails

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 

func GenerateCluster(name string, p cachev1alpha1.CacheClusterParameters, c *elasticachetypes.CacheCluster)

GenerateCluster modifies elasticache.CacheCluster with values from cachev1alpha1.CacheClusterParameters

func GenerateClusterObservation 

func GenerateClusterObservation(c elasticachetypes.CacheCluster) cachev1alpha1.CacheClusterObservation

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 

func GenerateObservation(rg elasticachetypes.ReplicationGroup) v1beta1.ReplicationGroupObservation

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 

func IsSubnetGroupUpToDate(p cachev1alpha1.CacheSubnetGroupParameters, sg elasticachetypes.CacheSubnetGroup) bool

IsSubnetGroupUpToDate checks if CacheSubnetGroupParameters are in sync with provider values

func LateInitialize 

func LateInitialize(s *v1beta1.ReplicationGroupParameters, rg elasticachetypes.ReplicationGroup, cc elasticachetypes.CacheCluster)

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 

func LateInitializeCluster(p *cachev1alpha1.CacheClusterParameters, c elasticachetypes.CacheCluster)

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 

func NewModifyReplicationGroupInput(g v1beta1.ReplicationGroupParameters, id string) *elasticache.ModifyReplicationGroupInput

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

func NewModifyReplicationGroupShardConfigurationInput 

func NewModifyReplicationGroupShardConfigurationInput(g v1beta1.ReplicationGroupParameters, id string, rg elasticachetypes.ReplicationGroup) *elasticache.ModifyReplicationGroupShardConfigurationInput

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

func ReplicationGroupNeedsUpdate 

func ReplicationGroupNeedsUpdate(kube v1beta1.ReplicationGroupParameters, rg elasticachetypes.ReplicationGroup, ccList []elasticachetypes.CacheCluster) string

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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.