elasticache

package
v0.27.1 Latest Latest
Warning

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

 Go to latest Published: Jun 10, 2022 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 added in v0.27.0 

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 added in v0.12.0 

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

GenerateCluster modifies elasticache.CacheCluster with values from cachev1alpha1.CacheClusterParameters

func GenerateClusterObservation added in v0.12.0 

func GenerateClusterObservation(c elasticachetypes.CacheCluster) cachev1alpha1.CacheClusterObservation

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

func GenerateCreateCacheClusterInput added in v0.12.0 

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

GenerateCreateCacheClusterInput returns Cache Cluster creation input

func GenerateModifyCacheClusterInput added in v0.12.0 

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 added in v0.12.0 

func IsClusterNotFound(err error) bool

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

func IsClusterUpToDate added in v0.12.0 

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 added in v0.9.0 

func IsSubnetGroupNotFound(err error) bool

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

func IsSubnetGroupUpToDate added in v0.9.0 

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 added in v0.12.0 

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 added in v0.27.0 

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 added in v0.27.0 

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

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

func NewListTagsForResourceInput added in v0.27.0 

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 added in v0.24.0 

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) bool

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

func ReplicationGroupNumCacheClustersNeedsUpdate added in v0.27.0 

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 added in v0.24.0 

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

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

func ReplicationGroupTagsNeedsUpdate added in v0.27.0 

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.

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.