elasticache

Documentation

Index

• func ConnectionEndpoint(rg elasticache.ReplicationGroup) managed.ConnectionDetails
• func GenerateCluster(name string, p cachev1alpha1.CacheClusterParameters, ...)
• func GenerateClusterObservation(c elasticache.CacheCluster) cachev1alpha1.CacheClusterObservation
• func GenerateCreateCacheClusterInput(p cachev1alpha1.CacheClusterParameters, id string) *elasticache.CreateCacheClusterInput
• func GenerateModifyCacheClusterInput(p cachev1alpha1.CacheClusterParameters, id string) *elasticache.ModifyCacheClusterInput
• func GenerateObservation(rg elasticache.ReplicationGroup) v1beta1.ReplicationGroupObservation
• func IsAlreadyExists(err error) bool
• func IsClusterNotFound(err error) bool
• func IsClusterUpToDate(name string, in *cachev1alpha1.CacheClusterParameters, ...) (bool, error)
• func IsNotFound(err error) bool
• func IsSubnetGroupNotFound(err error) bool
• func IsSubnetGroupUpToDate(p cachev1alpha1.CacheSubnetGroupParameters, sg elasticache.CacheSubnetGroup) bool
• func LateInitialize(s *v1beta1.ReplicationGroupParameters, rg elasticache.ReplicationGroup, ...)
• func LateInitializeCluster(p *cachev1alpha1.CacheClusterParameters, c elasticache.CacheCluster)
• func NewCreateReplicationGroupInput(g v1beta1.ReplicationGroupParameters, id string, authToken *string) *elasticache.CreateReplicationGroupInput
• func NewDeleteReplicationGroupInput(id string) *elasticache.DeleteReplicationGroupInput
• func NewDescribeCacheClustersInput(clusterID string) *elasticache.DescribeCacheClustersInput
• func NewDescribeReplicationGroupsInput(id string) *elasticache.DescribeReplicationGroupsInput
• func NewModifyReplicationGroupInput(g v1beta1.ReplicationGroupParameters, id string) *elasticache.ModifyReplicationGroupInput
• func ReplicationGroupNeedsUpdate(kube v1beta1.ReplicationGroupParameters, rg elasticache.ReplicationGroup, ...) bool
• type Client
  • func NewClient(cfg aws.Config) Client

Functions

func ConnectionEndpoint

func ConnectionEndpoint(rg elasticache.ReplicationGroup) managed.ConnectionDetails

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

func GenerateCluster

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

GenerateCluster modifies elasticache.CacheCluster with values from cachev1alpha1.CacheClusterParameters

func GenerateClusterObservation

func GenerateClusterObservation(c elasticache.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 elasticache.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 *elasticache.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 elasticache.CacheSubnetGroup) bool

IsSubnetGroupUpToDate checks if CacheSubnetGroupParameters are in sync with provider values

func LateInitialize

func LateInitialize(s *v1beta1.ReplicationGroupParameters, rg elasticache.ReplicationGroup, cc elasticache.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 elasticache.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 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 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 ReplicationGroupNeedsUpdate

func ReplicationGroupNeedsUpdate(kube v1beta1.ReplicationGroupParameters, rg elasticache.ReplicationGroup, ccList []elasticache.CacheCluster) bool

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

Types

type Client

type Client elasticacheiface.ClientAPI

A Client handles CRUD operations for ElastiCache resources. This interface is compatible with the upstream AWS redis client.

func NewClient

func NewClient(cfg aws.Config) Client

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