elasticache

package

Go to main page

Versions in this module

v1

v1.3.0

Aug 3, 2026

v1.2.0

Aug 3, 2026

Changes in this version

+ var ErrClusterNotAvailable = errors.New("cache cluster is not in the available state")

+ var ErrGlobalReplicationGroupNotAvailable = errors.New("global replication group is not in the available state")

+ var ErrReplicationGroupNotAvailable = errors.New("replication group is not in the available state")

+ var ErrServerlessCacheNotAvailable = errors.New("serverless cache is not in the available state")

+ type CacheUsageLimits struct

+ DataStorage *DataStorageLimit

+ ECPUPerSecond *ECPUPerSecondLimit

+ type DataStorageLimit struct

+ Maximum int32

+ Minimum int32

+ Unit string

+ type ECPUPerSecondLimit struct

+ Maximum int32

+ Minimum int32

type InMemoryBackend

+ func (b *InMemoryBackend) CreateUserWithAuth(ctx context.Context, userID, userName, accessString, engine, authType string, ...) (*User, error)

+ func (b *InMemoryBackend) ModifyUserWithAuth(ctx context.Context, ...) (*User, error)

+ func (b *InMemoryBackend) TaggedResources() []TaggedEntry

type ServerlessCache

+ CacheUsageLimits *CacheUsageLimits

+ type ServerlessCacheConfigSnapshot struct

+ Engine string

+ MajorEngineVersion string

+ ServerlessCacheName string

type ServerlessCacheSnapshot

+ BytesUsedForCache string

+ ExpiryTime time.Time

+ KmsKeyID string

+ ServerlessCacheConfiguration *ServerlessCacheConfigSnapshot

type ServerlessCreateOpts

+ CacheUsageLimits *CacheUsageLimits

type ServerlessModifyOpts

+ CacheUsageLimits *CacheUsageLimits

type StorageBackend

+ CreateUserWithAuth func(ctx context.Context, userID, userName, accessString, engine, authType string, ...) (*User, error)

+ ModifyUserWithAuth func(ctx context.Context, ...) (*User, error)

+ type TaggedEntry struct

+ ARN string

+ Tags map[string]string

type User

+ AuthType string

+ PasswordCount int

+ UserGroupIDs []string

v1.1.4

Jul 20, 2026

v1.1.3

Jul 20, 2026

v1.1.2

Jul 20, 2026

v1.1.1

Jul 20, 2026

v1.1.0

Jul 19, 2026

Changes in this version

+ const EngineDocker

+ const EngineEmbedded

+ const EngineStub

+ var ErrAuthTokenRequiredForMode = errors.New("auth token must be provided when transit encryption mode is 'required'")

+ var ErrCacheSecurityGroupAlreadyExists = errors.New("CacheSecurityGroupAlreadyExists")

+ var ErrCacheSecurityGroupNotFound = errors.New("CacheSecurityGroupNotFound")

+ var ErrClusterAlreadyExists = errors.New("CacheClusterAlreadyExists")

+ var ErrClusterModeRequired = errors.New("cluster mode must be enabled for shard configuration changes")

+ var ErrClusterNotFound = errors.New("CacheClusterNotFound")

+ var ErrDataTieringInvalid = errors.New("data tiering requires r7g node type and Redis/Valkey 7.0+")

+ var ErrGlobalReplicationGroupExists = errors.New("GlobalReplicationGroupAlreadyExistsFault")

+ var ErrGlobalReplicationGroupNotFound = errors.New("GlobalReplicationGroupNotFound")

+ var ErrGroupUserNotFound = errors.New("one or more specified user IDs do not exist")

+ var ErrInvalidParameterGroupFamily = errors.New("InvalidParameterGroupFamily")

+ var ErrInvalidSnapshotSource = errors.New("exactly one of CacheClusterId or ReplicationGroupId must be specified")

+ var ErrNilContext = errors.New("nil context")

+ var ErrParameterGroupAlreadyExists = errors.New("CacheParameterGroupAlreadyExists")

+ var ErrParameterGroupDefaultNotModifiable = errors.New("default parameter group cannot be deleted or modified")

+ var ErrParameterGroupNotFound = errors.New("CacheParameterGroupNotFound")

+ var ErrReplicationGroupAlreadyExists = errors.New("ReplicationGroupAlreadyExists")

+ var ErrReplicationGroupNotFound = errors.New("ReplicationGroupNotFound")

+ var ErrReservedCacheNodeAlreadyExists = errors.New("ReservedCacheNodeAlreadyExists")

+ var ErrReservedCacheNodeNotFound = errors.New("ReservedCacheNodeNotFound")

+ var ErrReservedCacheNodesOfferingNotFound = errors.New("ReservedCacheNodesOfferingNotFound")

+ var ErrResourceNotFound = errors.New("resource not found")

+ var ErrServerlessCacheAlreadyExists = errors.New("ServerlessCacheAlreadyExistsFault")

+ var ErrServerlessCacheNotFound = errors.New("ServerlessCacheNotFound")

+ var ErrServerlessCacheSnapshotExists = errors.New("ServerlessCacheSnapshotAlreadyExistsFault")

+ var ErrServerlessCacheSnapshotNotFound = errors.New("ServerlessCacheSnapshotNotFoundFault")

+ var ErrSnapshotAlreadyExists = errors.New("SnapshotAlreadyExistsFault")

+ var ErrSnapshotNotFound = errors.New("SnapshotNotFound")

+ var ErrSubnetGroupAlreadyExists = errors.New("CacheSubnetGroupAlreadyExists")

+ var ErrSubnetGroupNotFound = errors.New("CacheSubnetGroupNotFound")

+ var ErrTransitEncryptionModeInvalid = errors.New("transit encryption mode 'required' requires an auth token")

+ var ErrUserAlreadyExists = errors.New("UserAlreadyExists")

+ var ErrUserGroupAlreadyExists = errors.New("UserGroupAlreadyExistsFault")

+ var ErrUserGroupNotFound = errors.New("UserGroupNotFound")

+ var ErrUserNotFound = errors.New("UserNotFound")

+ var ErrUserNotFound2 = ErrUserNotFound

+ var ErrUserNotInGroup = errors.New("user is a member of a user group and cannot be deleted")

+ type BatchUpdateResult struct

+ ProcessedUpdateActions []UpdateActionResult

+ UnprocessedUpdateActions []UpdateActionResult

+ type CacheEngineVersion struct

+ CacheEngineDescription string

+ CacheEngineVersionDescription string

+ CacheParameterGroupFamily string

+ Engine string

+ EngineVersion string

+ type CacheEvent struct

+ Date time.Time

+ Message string

+ SourceIdentifier string

+ SourceType string

+ type CacheNodeMember struct

+ CacheClusterID string

+ CacheNodeCreateTime time.Time

+ CacheNodeID string

+ CacheNodeStatus string

+ Endpoint struct{ ... }

+ PreferredAvailabilityZone string

+ type CacheParameter struct

+ AllowedValues string

+ DataType string

+ Description string

+ IsModifiable bool

+ Name string

+ Value string

+ type CacheParameterGroup struct

+ ARN string

+ Description string

+ Family string

+ IsGlobal bool

+ Name string

+ Parameters map[string]string

+ Tags *tags.Tags

+ type CacheSecurityGroup struct

+ ARN string

+ Description string

+ Name string

+ OwnerID string

+ Tags *tags.Tags

+ type CacheSnapshot struct

+ ARN string

+ AvailableAt time.Time

+ CacheClusterID string

+ CreatedAt time.Time

+ Engine string

+ EngineVersion string

+ KmsKeyID string

+ NodeType string

+ PendingStatus string

+ ReplicationGroupID string

+ SnapshotName string

+ SnapshotSource string

+ Status string

+ Tags *tags.Tags

+ type CacheSubnetGroup struct

+ ARN string

+ Description string

+ Name string

+ SubnetIDs []string

+ Tags *tags.Tags

+ VpcID string

+ type Cluster struct

+ ARN string

+ AllocatedPort int

+ AtRestEncryptionEnabled bool

+ AvailableAt time.Time

+ CacheParameterGroupName string

+ ClusterID string

+ ConnectAddress string

+ CreatedAt time.Time

+ Endpoint string

+ Engine string

+ EngineVersion string

+ KmsKeyID string

+ Members []CacheNodeMember

+ NodeType string

+ NumCacheNodes int

+ PendingStatus string

+ Port int

+ PreferredMaintenanceWindow string

+ Region string

+ ReplicationGroupID string

+ SnapshotWindow string

+ Status string

+ Tags *tags.Tags

+ TransitEncryptionEnabled bool

+ TransitEncryptionMode string

+ type DNSRegistrar interface

+ Deregister func(hostname string)

+ Register func(hostname string)

+ type EC2SecurityGroupMembership struct

+ EC2SecurityGroupName string

+ EC2SecurityGroupOwnerID string

+ Status string

+ type EngineConfig interface

+ GetElastiCacheEngine func() string

+ type GlobalReplicationGroup struct

+ ARN string

+ AvailableAt time.Time

+ CreatedAt time.Time

+ Description string

+ Engine string

+ EngineVersion string

+ GlobalReplicationGroupID string

+ NodeGroupCount int32

+ PendingStatus string

+ PrimaryReplicationGroupRegion string

+ SecondaryReplicationGroups map[string]string

+ Status string

+ Tags *tags.Tags

+ type Handler struct

+ AccountID string

+ Backend StorageBackend

+ Region string

+ func NewHandler(backend StorageBackend) *Handler

+ func (h *Handler) ChaosOperations() []string

+ func (h *Handler) ChaosRegions() []string

+ func (h *Handler) ChaosServiceName() string

+ func (h *Handler) ExtractOperation(c *echo.Context) string

+ func (h *Handler) ExtractResource(c *echo.Context) string

+ func (h *Handler) GetSupportedOperations() []string

+ func (h *Handler) Handler() echo.HandlerFunc

+ func (h *Handler) MatchPriority() int

+ func (h *Handler) Name() string

+ func (h *Handler) Reset()

+ func (h *Handler) Restore(ctx context.Context, data []byte) error

+ func (h *Handler) RouteMatcher() service.Matcher

+ func (h *Handler) Snapshot(ctx context.Context) []byte

+ type InMemoryBackend struct

+ func NewInMemoryBackend(engineMode, accountID, region string, allocator *portalloc.Allocator) *InMemoryBackend

+ func (b *InMemoryBackend) AddCacheSecurityGroupInternal(sg *CacheSecurityGroup)

+ func (b *InMemoryBackend) AddGlobalReplicationGroupInternal(grg *GlobalReplicationGroup)

+ func (b *InMemoryBackend) AddServerlessCacheInternal(sc *ServerlessCache)

+ func (b *InMemoryBackend) AddServerlessCacheSnapshotInternal(snap *ServerlessCacheSnapshot)

+ func (b *InMemoryBackend) AddTagsToResource(_ context.Context, resourceARN string, newTags map[string]string) error

+ func (b *InMemoryBackend) AddUserGroupInternal(ug *UserGroup)

+ func (b *InMemoryBackend) AddUserInternal(u *User)

+ func (b *InMemoryBackend) AppendUpdateActions(actions []*UpdateAction)

+ func (b *InMemoryBackend) AuthorizeCacheSecurityGroupIngress(ctx context.Context, ...) (*CacheSecurityGroup, error)

+ func (b *InMemoryBackend) BatchApplyUpdateAction(_ context.Context, replicationGroupIDs, cacheClusterIDs []string, ...) (*BatchUpdateResult, error)

+ func (b *InMemoryBackend) BatchStopUpdateAction(_ context.Context, replicationGroupIDs, cacheClusterIDs []string, ...) (*BatchUpdateResult, error)

+ func (b *InMemoryBackend) CompleteMigration(ctx context.Context, replicationGroupID string, _ bool) (*ReplicationGroup, error)

+ func (b *InMemoryBackend) CopyServerlessCacheSnapshot(ctx context.Context, sourceSnapshotName, targetSnapshotName string) (*ServerlessCacheSnapshot, error)

+ func (b *InMemoryBackend) CopySnapshot(ctx context.Context, sourceSnapshotName, targetSnapshotName string) (*CacheSnapshot, error)

+ func (b *InMemoryBackend) CopySnapshotFull(ctx context.Context, sourceSnapshotName, targetSnapshotName, kmsKeyID string) (*CacheSnapshot, error)

+ func (b *InMemoryBackend) CreateCacheSecurityGroup(ctx context.Context, name, description string) (*CacheSecurityGroup, error)

+ func (b *InMemoryBackend) CreateCluster(ctx context.Context, id, engine, nodeType string, port int) (*Cluster, error)

+ func (b *InMemoryBackend) CreateClusterWithOptions(ctx context.Context, ...) (*Cluster, error)

+ func (b *InMemoryBackend) CreateGlobalReplicationGroup(ctx context.Context, ...) (*GlobalReplicationGroup, error)

+ func (b *InMemoryBackend) CreateParameterGroup(ctx context.Context, name, family, description string) (*CacheParameterGroup, error)

+ func (b *InMemoryBackend) CreateReplicationGroup(ctx context.Context, id, description string) (*ReplicationGroup, error)

+ func (b *InMemoryBackend) CreateReplicationGroupFull(ctx context.Context, opts ReplicationGroupCreateOpts) (*ReplicationGroup, error)

+ func (b *InMemoryBackend) CreateReplicationGroupWithOptions(ctx context.Context, ...) (*ReplicationGroup, error)

+ func (b *InMemoryBackend) CreateServerlessCache(ctx context.Context, name, description, engine string) (*ServerlessCache, error)

+ func (b *InMemoryBackend) CreateServerlessCacheFull(ctx context.Context, opts ServerlessCreateOpts) (*ServerlessCache, error)

+ func (b *InMemoryBackend) CreateServerlessCacheSnapshot(ctx context.Context, snapshotName, serverlessCacheName string) (*ServerlessCacheSnapshot, error)

+ func (b *InMemoryBackend) CreateSnapshot(ctx context.Context, snapshotName, clusterID, replicationGroupID string) (*CacheSnapshot, error)

+ func (b *InMemoryBackend) CreateSubnetGroup(ctx context.Context, name, description string, subnetIDs []string) (*CacheSubnetGroup, error)

+ func (b *InMemoryBackend) CreateSubnetGroupFull(ctx context.Context, name, description, vpcID string, subnetIDs []string) (*CacheSubnetGroup, error)

+ func (b *InMemoryBackend) CreateUser(ctx context.Context, userID, userName, accessString, engine string, ...) (*User, error)

+ func (b *InMemoryBackend) CreateUserGroup(ctx context.Context, groupID, description, engine string, userIDs []string) (*UserGroup, error)

+ func (b *InMemoryBackend) CreateUserGroupValidated(ctx context.Context, groupID, description, engine string, userIDs []string) (*UserGroup, error)

+ func (b *InMemoryBackend) DecreaseNodeGroupsInGlobalReplicationGroup(_ context.Context, id string, nodeGroupCount int32) (*GlobalReplicationGroup, error)

+ func (b *InMemoryBackend) DecreaseReplicaCount(ctx context.Context, replicationGroupID string, newReplicaCount int32) (*ReplicationGroup, error)

+ func (b *InMemoryBackend) DeleteCacheSecurityGroup(ctx context.Context, name string) error

+ func (b *InMemoryBackend) DeleteCluster(ctx context.Context, id string) error

+ func (b *InMemoryBackend) DeleteGlobalReplicationGroup(_ context.Context, id string, _ bool) (*GlobalReplicationGroup, error)

+ func (b *InMemoryBackend) DeleteParameterGroup(ctx context.Context, name string) error

+ func (b *InMemoryBackend) DeleteReplicationGroup(ctx context.Context, id string) error

+ func (b *InMemoryBackend) DeleteServerlessCache(ctx context.Context, name string) (*ServerlessCache, error)

+ func (b *InMemoryBackend) DeleteServerlessCacheSnapshot(ctx context.Context, name string) (*ServerlessCacheSnapshot, error)

+ func (b *InMemoryBackend) DeleteSnapshot(ctx context.Context, snapshotName string) (*CacheSnapshot, error)

+ func (b *InMemoryBackend) DeleteSubnetGroup(ctx context.Context, name string) error

+ func (b *InMemoryBackend) DeleteUser(ctx context.Context, userID string) (*User, error)

+ func (b *InMemoryBackend) DeleteUserGroup(ctx context.Context, groupID string) (*UserGroup, error)

+ func (b *InMemoryBackend) DeleteUserSafe(ctx context.Context, userID string) (*User, error)

+ func (b *InMemoryBackend) DescribeCacheEngineVersions(_ context.Context, engine, family, engineVersion, marker string, ...) (page.Page[CacheEngineVersion], error)

+ func (b *InMemoryBackend) DescribeCacheSecurityGroups(ctx context.Context, name, marker string, maxRecords int) (page.Page[CacheSecurityGroup], error)

+ func (b *InMemoryBackend) DescribeClusters(ctx context.Context, id, marker string, maxRecords int, notInRG bool) (page.Page[Cluster], error)

+ func (b *InMemoryBackend) DescribeEngineDefaultParameters(_ context.Context, cacheParameterGroupFamily string, marker string, ...) (page.Page[CacheParameter], error)

+ func (b *InMemoryBackend) DescribeEvents(_ context.Context, sourceIdentifier, sourceType, marker string, ...) (page.Page[CacheEvent], error)

+ func (b *InMemoryBackend) DescribeGlobalReplicationGroups(_ context.Context, id, marker string, maxRecords int) (page.Page[GlobalReplicationGroup], error)

+ func (b *InMemoryBackend) DescribeParameterGroups(ctx context.Context, name, marker string, maxRecords int) (page.Page[CacheParameterGroup], error)

+ func (b *InMemoryBackend) DescribeParameters(ctx context.Context, name, marker string, maxRecords int) (page.Page[CacheParameter], error)

+ func (b *InMemoryBackend) DescribeReplicationGroups(ctx context.Context, id, marker string, maxRecords int) (page.Page[ReplicationGroup], error)

+ func (b *InMemoryBackend) DescribeReservedCacheNodes(ctx context.Context, id, cacheNodeType, offeringType, marker string, ...) (page.Page[ReservedCacheNode], error)

+ func (b *InMemoryBackend) DescribeReservedCacheNodesOfferings(_ context.Context, offeringID, cacheNodeType, offeringType, marker string, ...) (page.Page[ReservedCacheNodesOffering], error)

+ func (b *InMemoryBackend) DescribeServerlessCacheSnapshots(ctx context.Context, serverlessCacheName, snapshotName, marker string, ...) (page.Page[ServerlessCacheSnapshot], error)

+ func (b *InMemoryBackend) DescribeServerlessCaches(ctx context.Context, name, marker string, maxRecords int) (page.Page[ServerlessCache], error)

+ func (b *InMemoryBackend) DescribeServiceUpdates(_ context.Context, serviceUpdateName string, marker string, maxRecords int, ...) (page.Page[ServiceUpdate], error)

+ func (b *InMemoryBackend) DescribeServiceUpdatesFull(serviceUpdateName string, status []string, marker string, maxRecords int) ([]ServiceUpdate, string, error)

+ func (b *InMemoryBackend) DescribeSnapshots(ctx context.Context, ...) (page.Page[CacheSnapshot], error)

+ func (b *InMemoryBackend) DescribeSubnetGroups(ctx context.Context, name, marker string, maxRecords int) (page.Page[CacheSubnetGroup], error)

+ func (b *InMemoryBackend) DescribeUpdateActions(_ context.Context, serviceUpdateName string, marker string, maxRecords int) (page.Page[UpdateAction], error)

+ func (b *InMemoryBackend) DescribeUpdateActionsFull(serviceUpdateName, marker string, maxRecords int) ([]UpdateAction, string, error)

+ func (b *InMemoryBackend) DescribeUserGroups(ctx context.Context, groupID, marker string, maxRecords int) (page.Page[UserGroup], error)

+ func (b *InMemoryBackend) DescribeUsers(ctx context.Context, userID, marker string, maxRecords int) (page.Page[User], error)

+ func (b *InMemoryBackend) DisassociateGlobalReplicationGroup(_ context.Context, id, _, _ string) (*GlobalReplicationGroup, error)

+ func (b *InMemoryBackend) ExportServerlessCacheSnapshot(ctx context.Context, snapshotName, _ string) (*ServerlessCacheSnapshot, error)

+ func (b *InMemoryBackend) FailoverGlobalReplicationGroup(_ context.Context, id, _, _ string) (*GlobalReplicationGroup, error)

+ func (b *InMemoryBackend) FailoverReplicationGroup(ctx context.Context, id, _ string) (*ReplicationGroup, error)

+ func (b *InMemoryBackend) IncreaseNodeGroupsInGlobalReplicationGroup(_ context.Context, id string, nodeGroupCount int32) (*GlobalReplicationGroup, error)

+ func (b *InMemoryBackend) IncreaseReplicaCount(ctx context.Context, replicationGroupID string, newReplicaCount int32) (*ReplicationGroup, error)

+ func (b *InMemoryBackend) ListAll() []Cluster

+ func (b *InMemoryBackend) ListAllowedNodeTypeModifications(_ context.Context, _, _ string) ([]string, error)

+ func (b *InMemoryBackend) ListTagsForResource(_ context.Context, arn string) (map[string]string, error)

+ func (b *InMemoryBackend) ListUpdateActionsByServiceUpdate(serviceUpdateName string) []*UpdateAction

+ func (b *InMemoryBackend) ModifyCluster(ctx context.Context, ...) (*Cluster, error)

+ func (b *InMemoryBackend) ModifyGlobalReplicationGroup(_ context.Context, id, description, engineVersion string, ...) (*GlobalReplicationGroup, error)

+ func (b *InMemoryBackend) ModifyParameterGroup(ctx context.Context, name string, params map[string]string) (*CacheParameterGroup, error)

+ func (b *InMemoryBackend) ModifyReplicationGroup(ctx context.Context, ...) (*ReplicationGroup, error)

+ func (b *InMemoryBackend) ModifyReplicationGroupFull(ctx context.Context, id string, opts ReplicationGroupModifyOpts) (*ReplicationGroup, error)

+ func (b *InMemoryBackend) ModifyReplicationGroupShardConfiguration(ctx context.Context, replicationGroupID string, nodeGroupCount int32) (*ReplicationGroup, error)

+ func (b *InMemoryBackend) ModifyServerlessCache(ctx context.Context, name, description string) (*ServerlessCache, error)

+ func (b *InMemoryBackend) ModifyServerlessCacheFull(ctx context.Context, name string, opts ServerlessModifyOpts) (*ServerlessCache, error)

+ func (b *InMemoryBackend) ModifySubnetGroup(ctx context.Context, name, description string, subnetIDs []string) (*CacheSubnetGroup, error)

+ func (b *InMemoryBackend) ModifyUser(ctx context.Context, userID, accessString string, noPasswordRequired bool) (*User, error)

+ func (b *InMemoryBackend) ModifyUserGroup(ctx context.Context, groupID string, userIDsToAdd, userIDsToRemove []string) (*UserGroup, error)

+ func (b *InMemoryBackend) PurchaseReservedCacheNodesOffering(ctx context.Context, offeringID, reservedCacheNodeID string, ...) (*ReservedCacheNode, error)

+ func (b *InMemoryBackend) RebalanceSlotsInGlobalReplicationGroup(_ context.Context, id string) (*GlobalReplicationGroup, error)

+ func (b *InMemoryBackend) RebootCacheCluster(ctx context.Context, clusterID string, nodeIDs []string) (*Cluster, error)

+ func (b *InMemoryBackend) Region() string

+ func (b *InMemoryBackend) RemoveTagsFromResource(_ context.Context, resourceARN string, tagKeys []string) error

+ func (b *InMemoryBackend) Reset()

+ func (b *InMemoryBackend) ResetParameterGroup(ctx context.Context, name string, paramNames []string, resetAll bool) (*CacheParameterGroup, error)

+ func (b *InMemoryBackend) Restore(ctx context.Context, data []byte) error

+ func (b *InMemoryBackend) RevokeCacheSecurityGroupIngress(ctx context.Context, ...) (*CacheSecurityGroup, error)

+ func (b *InMemoryBackend) SetClock(clock func() time.Time)

+ func (b *InMemoryBackend) SetDNSRegistrar(r DNSRegistrar)

+ func (b *InMemoryBackend) SetLifecycleDelay(d time.Duration)

+ func (b *InMemoryBackend) Snapshot(ctx context.Context) []byte

+ func (b *InMemoryBackend) StartMigration(ctx context.Context, replicationGroupID string) (*ReplicationGroup, error)

+ func (b *InMemoryBackend) TestMigration(ctx context.Context, replicationGroupID string) (*ReplicationGroup, error)

+ func (b *InMemoryBackend) TriggerAutoSnapshot(ctx context.Context, replicationGroupID string) (*CacheSnapshot, error)

+ type LogDeliveryConfig struct

+ DestinationDetails string

+ DestinationType string

+ LogFormat string

+ LogType string

+ Message string

+ Status string

+ type NodeGroup struct

+ NodeGroupID string

+ PrimaryNode *NodeGroupNode

+ Replicas []NodeGroupNode

+ Slots string

+ Status string

+ type NodeGroupNode struct

+ CacheClusterID string

+ CacheNodeID string

+ CurrentRole string

+ PreferredAvailabilityZone string

+ ReadEndpointAddress string

+ ReadEndpointPort int

+ type Provider struct

+ func (p *Provider) Init(ctx *service.AppContext) (service.Registerable, error)

+ func (p *Provider) Name() string

+ type RGPendingModifiedValues struct

+ AuthTokenStatus string

+ AutomaticFailoverStatus string

+ CacheNodeType string

+ EngineVersion string

+ ReplicaCount *int32

+ type ReplicationGroup struct

+ ARN string

+ AtRestEncryptionEnabled bool

+ AuthToken string

+ AuthTokenEnabled bool

+ AuthTokenLastModifiedDate *time.Time

+ AutomaticFailover string

+ AvailableAt time.Time

+ CacheNodeType string

+ CacheParameterGroupName string

+ ClusterModeEnabled bool

+ CreatedAt time.Time

+ DataTieringEnabled bool

+ Description string

+ Engine string

+ EngineVersion string

+ KmsKeyID string

+ LogDeliveryConfigurations []LogDeliveryConfig

+ MultiAZEnabled bool

+ NodeGroups []NodeGroup

+ NotificationTopicArn string

+ PendingModifiedValues *RGPendingModifiedValues

+ PendingStatus string

+ PreferredMaintenanceWindow string

+ ReplicaCount int32

+ ReplicationGroupID string

+ SnapshotRetentionLimit int

+ SnapshotWindow string

+ Status string

+ Tags *tags.Tags

+ TransitEncryptionEnabled bool

+ TransitEncryptionMode string

+ UserGroupIDs []string

+ type ReplicationGroupCreateOpts struct

+ AtRestEncryptionEnabled bool

+ AuthToken string

+ AuthTokenEnabled bool

+ AutomaticFailoverEnabled bool

+ CacheNodeType string

+ ClusterModeEnabled bool

+ DataTieringEnabled bool

+ Description string

+ Engine string

+ EngineVersion string

+ ID string

+ KmsKeyID string

+ LogDeliveryConfigurations []LogDeliveryConfig

+ MaintenanceWindow string

+ MultiAZEnabled bool

+ NotificationTopicArn string

+ NumNodeGroups int32

+ ParameterGroupName string

+ ReplicasPerNodeGroup int32

+ SnapshotName string

+ SnapshotRetentionLimit int

+ SnapshotWindow string

+ Tags map[string]string

+ TransitEncryptionEnabled bool

+ TransitEncryptionMode string

+ UserGroupIDs []string

+ type ReplicationGroupModifyOpts struct

+ ApplyImmediately bool

+ AuthToken string

+ AuthTokenUpdateStrategy string

+ AutomaticFailoverEnabled *bool

+ CacheNodeType string

+ Description string

+ EngineVersion string

+ LogDeliveryConfigurations []LogDeliveryConfig

+ MaintenanceWindow string

+ MultiAZEnabled *bool

+ NotificationTopicArn string

+ ParameterGroupName string

+ ReplicaCount *int32

+ SnapshotRetentionLimit *int

+ SnapshotWindow string

+ TransitEncryptionMode string

+ UserGroupIDsToAdd []string

+ UserGroupIDsToRemove []string

+ type ReservedCacheNode struct

+ ARN string

+ CacheNodeCount int32

+ CacheNodeType string

+ Duration int32

+ FixedPrice float64

+ OfferingID string

+ OfferingType string

+ ProductDescription string

+ ReservationID string

+ ReservedCacheNodeID string

+ StartTime time.Time

+ State string

+ UsagePrice float64

+ type ReservedCacheNodesOffering struct

+ CacheNodeType string

+ Duration int32

+ FixedPrice float64

+ OfferingID string

+ OfferingType string

+ ProductDescription string

+ UsagePrice float64

+ type ServerlessCache struct

+ ARN string

+ AvailableAt time.Time

+ CreatedAt time.Time

+ DailySnapshotTime string

+ Description string

+ Endpoint *ServerlessCacheEndpoint

+ Engine string

+ KmsKeyID string

+ MajorEngineVersion string

+ Name string

+ PendingStatus string

+ ReaderEndpoint *ServerlessCacheEndpoint

+ SecurityGroupIDs []string

+ SnapshotRetentionLimit int32

+ Status string

+ SubnetGroupName string

+ SubnetIDs []string

+ Tags *tags.Tags

+ UserGroupID string

+ type ServerlessCacheEndpoint struct

+ Address string

+ Port int

+ type ServerlessCacheSnapshot struct

+ ARN string

+ CreatedAt time.Time

+ Name string

+ ServerlessCacheName string

+ SnapshotType string

+ Status string

+ Tags *tags.Tags

+ type ServerlessCreateOpts struct

+ DailySnapshotTime string

+ Description string

+ Engine string

+ KmsKeyID string

+ MajorEngineVersion string

+ Name string

+ SecurityGroupIDs []string

+ SnapshotRetentionLimit int32

+ SubnetGroupName string

+ SubnetIDs []string

+ Tags map[string]string

+ UserGroupID string

+ type ServerlessModifyOpts struct

+ DailySnapshotTime string

+ Description string

+ RemoveUserGroup bool

+ SecurityGroupIDs []string

+ SnapshotRetentionLimit *int32

+ UserGroupID string

+ type ServiceUpdate struct

+ ServiceUpdateName string

+ Status string

+ func BuiltinServiceUpdates() []ServiceUpdate

+ type StorageBackend interface

+ AddTagsToResource func(ctx context.Context, arn string, newTags map[string]string) error

+ AppendUpdateActions func(actions []*UpdateAction)

+ AuthorizeCacheSecurityGroupIngress func(ctx context.Context, ...) (*CacheSecurityGroup, error)

+ BatchApplyUpdateAction func(ctx context.Context, replicationGroupIDs, cacheClusterIDs []string, ...) (*BatchUpdateResult, error)

+ BatchStopUpdateAction func(ctx context.Context, replicationGroupIDs, cacheClusterIDs []string, ...) (*BatchUpdateResult, error)

+ CompleteMigration func(ctx context.Context, replicationGroupID string, force bool) (*ReplicationGroup, error)

+ CopyServerlessCacheSnapshot func(ctx context.Context, sourceSnapshotName, targetSnapshotName string) (*ServerlessCacheSnapshot, error)

+ CopySnapshot func(ctx context.Context, sourceSnapshotName, targetSnapshotName string) (*CacheSnapshot, error)

+ CopySnapshotFull func(ctx context.Context, sourceSnapshotName, targetSnapshotName, kmsKeyID string) (*CacheSnapshot, error)

+ CreateCacheSecurityGroup func(ctx context.Context, name, description string) (*CacheSecurityGroup, error)

+ CreateCluster func(ctx context.Context, id, engine, nodeType string, port int) (*Cluster, error)

+ CreateClusterWithOptions func(ctx context.Context, ...) (*Cluster, error)

+ CreateGlobalReplicationGroup func(ctx context.Context, ...) (*GlobalReplicationGroup, error)

+ CreateParameterGroup func(ctx context.Context, name, family, description string) (*CacheParameterGroup, error)

+ CreateReplicationGroup func(ctx context.Context, id, description string) (*ReplicationGroup, error)

+ CreateReplicationGroupFull func(ctx context.Context, opts ReplicationGroupCreateOpts) (*ReplicationGroup, error)

+ CreateReplicationGroupWithOptions func(ctx context.Context, ...) (*ReplicationGroup, error)

+ CreateServerlessCache func(ctx context.Context, name, description, engine string) (*ServerlessCache, error)

+ CreateServerlessCacheFull func(ctx context.Context, opts ServerlessCreateOpts) (*ServerlessCache, error)

+ CreateServerlessCacheSnapshot func(ctx context.Context, snapshotName, serverlessCacheName string) (*ServerlessCacheSnapshot, error)

+ CreateSnapshot func(ctx context.Context, snapshotName, clusterID, replicationGroupID string) (*CacheSnapshot, error)

+ CreateSubnetGroup func(ctx context.Context, name, description string, subnetIDs []string) (*CacheSubnetGroup, error)

+ CreateSubnetGroupFull func(ctx context.Context, name, description, vpcID string, subnetIDs []string) (*CacheSubnetGroup, error)

+ CreateUser func(ctx context.Context, userID, userName, accessString, engine string, ...) (*User, error)

+ CreateUserGroup func(ctx context.Context, groupID, description, engine string, userIDs []string) (*UserGroup, error)

+ CreateUserGroupValidated func(ctx context.Context, groupID, description, engine string, userIDs []string) (*UserGroup, error)

+ DecreaseNodeGroupsInGlobalReplicationGroup func(ctx context.Context, id string, nodeGroupCount int32) (*GlobalReplicationGroup, error)

+ DecreaseReplicaCount func(ctx context.Context, replicationGroupID string, newReplicaCount int32) (*ReplicationGroup, error)

+ DeleteCacheSecurityGroup func(ctx context.Context, name string) error

+ DeleteCluster func(ctx context.Context, id string) error

+ DeleteGlobalReplicationGroup func(ctx context.Context, id string, retainPrimaryReplicationGroup bool) (*GlobalReplicationGroup, error)

+ DeleteParameterGroup func(ctx context.Context, name string) error

+ DeleteReplicationGroup func(ctx context.Context, id string) error

+ DeleteServerlessCache func(ctx context.Context, name string) (*ServerlessCache, error)

+ DeleteServerlessCacheSnapshot func(ctx context.Context, name string) (*ServerlessCacheSnapshot, error)

+ DeleteSnapshot func(ctx context.Context, snapshotName string) (*CacheSnapshot, error)

+ DeleteSubnetGroup func(ctx context.Context, name string) error

+ DeleteUser func(ctx context.Context, userID string) (*User, error)

+ DeleteUserGroup func(ctx context.Context, groupID string) (*UserGroup, error)

+ DescribeCacheEngineVersions func(ctx context.Context, engine, family, engineVersion, marker string, ...) (page.Page[CacheEngineVersion], error)

+ DescribeCacheSecurityGroups func(ctx context.Context, name, marker string, maxRecords int) (page.Page[CacheSecurityGroup], error)

+ DescribeClusters func(ctx context.Context, id, marker string, maxRecords int, notInRG bool) (page.Page[Cluster], error)

+ DescribeEngineDefaultParameters func(ctx context.Context, cacheParameterGroupFamily, marker string, maxRecords int) (page.Page[CacheParameter], error)

+ DescribeEvents func(ctx context.Context, sourceIdentifier, sourceType, marker string, ...) (page.Page[CacheEvent], error)

+ DescribeGlobalReplicationGroups func(ctx context.Context, id, marker string, maxRecords int) (page.Page[GlobalReplicationGroup], error)

+ DescribeParameterGroups func(ctx context.Context, name, marker string, maxRecords int) (page.Page[CacheParameterGroup], error)

+ DescribeParameters func(ctx context.Context, name, marker string, maxRecords int) (page.Page[CacheParameter], error)

+ DescribeReplicationGroups func(ctx context.Context, id, marker string, maxRecords int) (page.Page[ReplicationGroup], error)

+ DescribeReservedCacheNodes func(ctx context.Context, id, cacheNodeType, offeringType, marker string, ...) (page.Page[ReservedCacheNode], error)

+ DescribeReservedCacheNodesOfferings func(ctx context.Context, offeringID, cacheNodeType, offeringType, marker string, ...) (page.Page[ReservedCacheNodesOffering], error)

+ DescribeServerlessCacheSnapshots func(ctx context.Context, serverlessCacheName, snapshotName, marker string, ...) (page.Page[ServerlessCacheSnapshot], error)

+ DescribeServerlessCaches func(ctx context.Context, name, marker string, maxRecords int) (page.Page[ServerlessCache], error)

+ DescribeServiceUpdates func(ctx context.Context, serviceUpdateName, marker string, maxRecords int, ...) (page.Page[ServiceUpdate], error)

+ DescribeSnapshots func(ctx context.Context, ...) (page.Page[CacheSnapshot], error)

+ DescribeSubnetGroups func(ctx context.Context, name, marker string, maxRecords int) (page.Page[CacheSubnetGroup], error)

+ DescribeUpdateActions func(ctx context.Context, serviceUpdateName, marker string, maxRecords int) (page.Page[UpdateAction], error)

+ DescribeUserGroups func(ctx context.Context, groupID, marker string, maxRecords int) (page.Page[UserGroup], error)

+ DescribeUsers func(ctx context.Context, userID, marker string, maxRecords int) (page.Page[User], error)

+ DisassociateGlobalReplicationGroup func(ctx context.Context, id, replicationGroupID, replicationGroupRegion string) (*GlobalReplicationGroup, error)

+ ExportServerlessCacheSnapshot func(ctx context.Context, snapshotName, s3BucketName string) (*ServerlessCacheSnapshot, error)

+ FailoverGlobalReplicationGroup func(ctx context.Context, id, primaryRegion, primaryReplicationGroupID string) (*GlobalReplicationGroup, error)

+ FailoverReplicationGroup func(ctx context.Context, id, nodeGroupID string) (*ReplicationGroup, error)

+ IncreaseNodeGroupsInGlobalReplicationGroup func(ctx context.Context, id string, nodeGroupCount int32) (*GlobalReplicationGroup, error)

+ IncreaseReplicaCount func(ctx context.Context, replicationGroupID string, newReplicaCount int32) (*ReplicationGroup, error)

+ ListAllowedNodeTypeModifications func(ctx context.Context, clusterID, replicationGroupID string) ([]string, error)

+ ListTagsForResource func(ctx context.Context, arn string) (map[string]string, error)

+ ListUpdateActionsByServiceUpdate func(serviceUpdateName string) []*UpdateAction

+ ModifyCluster func(ctx context.Context, ...) (*Cluster, error)

+ ModifyGlobalReplicationGroup func(ctx context.Context, id, description, engineVersion string, ...) (*GlobalReplicationGroup, error)

+ ModifyParameterGroup func(ctx context.Context, name string, params map[string]string) (*CacheParameterGroup, error)

+ ModifyReplicationGroup func(ctx context.Context, ...) (*ReplicationGroup, error)

+ ModifyReplicationGroupFull func(ctx context.Context, id string, opts ReplicationGroupModifyOpts) (*ReplicationGroup, error)

+ ModifyReplicationGroupShardConfiguration func(ctx context.Context, replicationGroupID string, nodeGroupCount int32) (*ReplicationGroup, error)

+ ModifyServerlessCache func(ctx context.Context, name, description string) (*ServerlessCache, error)

+ ModifyServerlessCacheFull func(ctx context.Context, name string, opts ServerlessModifyOpts) (*ServerlessCache, error)

+ ModifySubnetGroup func(ctx context.Context, name, description string, subnetIDs []string) (*CacheSubnetGroup, error)

+ ModifyUser func(ctx context.Context, userID, accessString string, noPasswordRequired bool) (*User, error)

+ ModifyUserGroup func(ctx context.Context, groupID string, userIDsToAdd, userIDsToRemove []string) (*UserGroup, error)

+ PurchaseReservedCacheNodesOffering func(ctx context.Context, offeringID, reservedCacheNodeID string, ...) (*ReservedCacheNode, error)

+ RebalanceSlotsInGlobalReplicationGroup func(ctx context.Context, id string) (*GlobalReplicationGroup, error)

+ RebootCacheCluster func(ctx context.Context, clusterID string, nodeIDs []string) (*Cluster, error)

+ Region func() string

+ RemoveTagsFromResource func(ctx context.Context, arn string, tagKeys []string) error

+ ResetParameterGroup func(ctx context.Context, name string, paramNames []string, resetAll bool) (*CacheParameterGroup, error)

+ RevokeCacheSecurityGroupIngress func(ctx context.Context, ...) (*CacheSecurityGroup, error)

+ StartMigration func(ctx context.Context, replicationGroupID string) (*ReplicationGroup, error)

+ TestMigration func(ctx context.Context, replicationGroupID string) (*ReplicationGroup, error)

+ TriggerAutoSnapshot func(ctx context.Context, replicationGroupID string) (*CacheSnapshot, error)

+ type UpdateAction struct

+ CacheClusterID string

+ ReplicationGroupID string

+ ServiceUpdateName string

+ UpdateActionStatus string

+ type UpdateActionResult struct

+ CacheClusterID string

+ ReplicationGroupID string

+ ServiceUpdateName string

+ UpdateActionStatus string

+ type User struct

+ ARN string

+ AccessString string

+ CreatedAt time.Time

+ Engine string

+ NoPasswordRequired bool

+ Status string

+ Tags *tags.Tags

+ UserID string

+ UserName string

+ type UserGroup struct

+ ARN string

+ AssignedReplicationGroupIDs []string

+ CreatedAt time.Time

+ Description string

+ Engine string

+ Status string

+ Tags *tags.Tags

+ UserGroupID string

+ UserIDs []string

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