elasticache

Documentation

Index

• func ConnectionEndpoint(rg elasticache.ReplicationGroup) managed.ConnectionDetails
• func GenerateObservation(rg elasticache.ReplicationGroup) v1beta1.ReplicationGroupObservation
• func IsAlreadyExists(err error) bool
• func IsNotFound(err error) bool
• func LateInitialize(s *v1beta1.ReplicationGroupParameters, rg elasticache.ReplicationGroup)
• 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(ctx context.Context, credentials []byte, region string, ...) (Client, error)

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 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 IsNotFound

func IsNotFound(err error) bool

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

func LateInitialize

func LateInitialize(s *v1beta1.ReplicationGroupParameters, rg elasticache.ReplicationGroup)

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 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(ctx context.Context, credentials []byte, region string, auth clients.AuthMethod) (Client, error)

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