memorydb

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

type Cluster

+ AvailableAt time.Time

+ PendingStatus string

type InMemoryBackend

+ func (b *InMemoryBackend) RegionalClustersFor(multiRegionClusterName string) []*Cluster

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

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

type MultiRegionCluster

+ TLSEnabled bool

type ReservedNode

+ ReservedNodesOfferingID string

type ServiceUpdate

+ Engine string

type Snapshot

+ DataTiering string

type StorageBackend

+ RegionalClustersFor func(multiRegionClusterName string) []*Cluster

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

+ var ErrACLAlreadyExists = awserr.New("ACLAlreadyExistsFault: ACL already exists", awserr.ErrAlreadyExists)

+ var ErrACLInUse = awserr.New("InvalidACLStateFault: ACL is currently associated with a cluster", ...)

+ var ErrACLNotFound = awserr.New("ACLNotFoundFault: ACL not found", awserr.ErrNotFound)

+ var ErrClusterAlreadyExists = awserr.New("ClusterAlreadyExistsFault: cluster already exists", awserr.ErrAlreadyExists)

+ var ErrClusterNotFound = awserr.New("ClusterNotFoundFault: cluster not found", awserr.ErrNotFound)

+ var ErrInvalidARN = awserr.New("InvalidARNFault: resource not found for the given ARN", awserr.ErrNotFound)

+ var ErrMultiRegionClusterAlreadyExists = awserr.New("MultiRegionClusterAlreadyExistsFault: multi-region cluster already exists", ...)

+ var ErrMultiRegionClusterNotFound = awserr.New("MultiRegionClusterNotFoundFault: multi-region cluster not found", ...)

+ var ErrMultiRegionParameterGroupNotFound = awserr.New(...)

+ var ErrNilAppContext = errors.New("nil AppContext passed to MemoryDB Provider.Init")

+ var ErrParameterGroupAlreadyExists = awserr.New("ParameterGroupAlreadyExistsFault: parameter group already exists", ...)

+ var ErrParameterGroupNotFound = awserr.New("ParameterGroupNotFoundFault: parameter group not found", awserr.ErrNotFound)

+ var ErrReservationAlreadyExists = awserr.New("ReservedNodeAlreadyExistsFault: reserved node already exists", ...)

+ var ErrSnapshotAlreadyExists = awserr.New("SnapshotAlreadyExistsFault: snapshot already exists", awserr.ErrAlreadyExists)

+ var ErrSnapshotNotFound = awserr.New("SnapshotNotFoundFault: snapshot not found", awserr.ErrNotFound)

+ var ErrSubnetGroupAlreadyExists = awserr.New("SubnetGroupAlreadyExistsFault: subnet group already exists", ...)

+ var ErrSubnetGroupInUse = awserr.New("SubnetGroupInUseFault: subnet group is currently associated with a cluster", ...)

+ var ErrSubnetGroupNotFound = awserr.New("SubnetGroupNotFoundFault: subnet group not found", awserr.ErrNotFound)

+ var ErrUserAlreadyExists = awserr.New("UserAlreadyExistsFault: user already exists", awserr.ErrAlreadyExists)

+ var ErrUserInUse = awserr.New("InvalidUserStateFault: user is currently a member of an ACL", ...)

+ var ErrUserNotFound = awserr.New("UserNotFoundFault: user not found", awserr.ErrNotFound)

+ var ErrValidation = awserr.New("InvalidParameterValueException", awserr.ErrInvalidParameter)

+ func ACLCount(b *InMemoryBackend) int

+ func ARNIndexSize(b *InMemoryBackend) int

+ func ClusterCount(b *InMemoryBackend) int

+ func EventCount(b *InMemoryBackend) int

+ func HandlerOpsLen(h *Handler) int

+ func MultiRegionClusterCount(b *InMemoryBackend) int

+ func ParameterGroupCount(b *InMemoryBackend) int

+ func SnapshotCount(b *InMemoryBackend) int

+ func SubnetGroupCount(b *InMemoryBackend) int

+ func UserCount(b *InMemoryBackend) int

+ type ACL struct

+ ARN string

+ CreatedAt time.Time

+ Name string

+ Status string

+ Tags map[string]string

+ UserNames []string

+ type Cluster struct

+ ACLName string

+ ARN string

+ AutoMinorVersionUpgrade bool

+ AvailabilityMode string

+ CreatedAt time.Time

+ DataTiering string

+ Description string

+ Endpoint string

+ Engine string

+ EngineVersion string

+ IPDiscovery string

+ KmsKeyID string

+ MaintenanceWindow string

+ MultiRegionClusterName string

+ MultiRegionParameterGroupName string

+ Name string

+ NetworkType string

+ NodeType string

+ NumReplicasPerShard int32

+ NumShards int32

+ ParameterGroupName string

+ ParameterGroupStatus string

+ Port int32

+ Region string

+ SecurityGroupIDs []string

+ SnapshotRetentionLimit int32

+ SnapshotWindow string

+ SnsTopicArn string

+ SnsTopicStatus string

+ Status string

+ SubnetGroupName string

+ TLSEnabled bool

+ Tags map[string]string

+ type EngineVersion struct

+ Description string

+ Engine string

+ EnginePatchVersion string

+ EngineVersion string

+ ParameterGroupFamily string

+ type Event struct

+ Date time.Time

+ Message string

+ SourceName string

+ SourceType string

+ type ExportedAuthModeReq = authenticationModeReq

+ type ExportedCluster = Cluster

+ type ExportedCopySnapshotRequest = copySnapshotRequest

+ type ExportedCreateACLRequest = createACLRequest

+ type ExportedCreateClusterRequest = createClusterRequest

+ type ExportedCreateMultiRegionClusterRequest = createMultiRegionClusterRequest

+ type ExportedCreateParameterGroupRequest = createParameterGroupRequest

+ type ExportedCreateSnapshotRequest = createSnapshotRequest

+ type ExportedCreateSubnetGroupRequest = createSubnetGroupRequest

+ type ExportedCreateUserRequest = createUserRequest

+ type ExportedDescribeEngineVersionsRequest = describeEngineVersionsRequest

+ type ExportedDescribeEventsRequest = describeEventsRequest

+ type ExportedDescribeReservedNodesRequest = describeReservedNodesRequest

+ type ExportedEngineVersion = EngineVersion

+ type ExportedEvent = Event

+ type ExportedPurchaseReservedNodesOfferingRequest = purchaseReservedNodesOfferingRequest

+ type ExportedResetParameterGroupRequest = resetParameterGroupRequest

+ type ExportedUpdateClusterRequest = updateClusterRequest

+ type ExportedUpdateMultiRegionClusterRequest = updateMultiRegionClusterRequest

+ type Handler struct

+ AccountID string

+ Backend StorageBackend

+ DefaultRegion 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) Purge(ctx context.Context, cutoff time.Time)

+ 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(accountID, region string) *InMemoryBackend

+ func (b *InMemoryBackend) AddACLInternal(name string) *ACL

+ func (b *InMemoryBackend) AddClusterInternal(name, nodeType string) *Cluster

+ func (b *InMemoryBackend) AddEvent(ev *Event)

+ func (b *InMemoryBackend) AddMultiRegionParameterGroupInternal(name, family string) *MultiRegionParameterGroup

+ func (b *InMemoryBackend) AddParameterGroupInternal(name, family string) *ParameterGroup

+ func (b *InMemoryBackend) AddSnapshotInternal(name, clusterName string) *Snapshot

+ func (b *InMemoryBackend) AddSubnetGroupInternal(name string) *SubnetGroup

+ func (b *InMemoryBackend) AddUserInternal(name, accessString string) *User

+ func (b *InMemoryBackend) BatchUpdateCluster(ctx context.Context, clusterNames []string) map[string]*Cluster

+ func (b *InMemoryBackend) CopySnapshot(ctx context.Context, req *copySnapshotRequest) (*Snapshot, error)

+ func (b *InMemoryBackend) CreateACL(ctx context.Context, req *createACLRequest) (*ACL, error)

+ func (b *InMemoryBackend) CreateCluster(ctx context.Context, req *createClusterRequest) (*Cluster, error)

+ func (b *InMemoryBackend) CreateMultiRegionCluster(ctx context.Context, req *createMultiRegionClusterRequest) (*MultiRegionCluster, error)

+ func (b *InMemoryBackend) CreateParameterGroup(ctx context.Context, req *createParameterGroupRequest) (*ParameterGroup, error)

+ func (b *InMemoryBackend) CreateSnapshot(ctx context.Context, req *createSnapshotRequest) (*Snapshot, error)

+ func (b *InMemoryBackend) CreateSubnetGroup(ctx context.Context, req *createSubnetGroupRequest) (*SubnetGroup, error)

+ func (b *InMemoryBackend) CreateUser(ctx context.Context, req *createUserRequest) (*User, error)

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

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

+ func (b *InMemoryBackend) DeleteClusterWithSnapshot(ctx context.Context, clusterName, snapshotName string) (*Cluster, error)

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

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

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

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

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

+ func (b *InMemoryBackend) DescribeACLs(ctx context.Context, name string) ([]*ACL, error)

+ func (b *InMemoryBackend) DescribeClusters(ctx context.Context, name string) ([]*Cluster, error)

+ func (b *InMemoryBackend) DescribeEngineVersions(_ context.Context, req *describeEngineVersionsRequest) ([]*EngineVersion, error)

+ func (b *InMemoryBackend) DescribeEvents(_ context.Context, req *describeEventsRequest) ([]*Event, error)

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

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

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

+ func (b *InMemoryBackend) DescribeParameterGroups(ctx context.Context, name string) ([]*ParameterGroup, error)

+ func (b *InMemoryBackend) DescribeParameters(ctx context.Context, parameterGroupName string) (map[string]string, error)

+ func (b *InMemoryBackend) DescribeReservedNodes(ctx context.Context, req *describeReservedNodesRequest) ([]*ReservedNode, error)

+ func (b *InMemoryBackend) DescribeReservedNodesOfferings(_ context.Context, req *describeReservedNodesOfferingsRequest) ([]*ReservedNodesOffering, error)

+ func (b *InMemoryBackend) DescribeServiceUpdates(_ context.Context, req *describeServiceUpdatesRequest) ([]*ServiceUpdate, error)

+ func (b *InMemoryBackend) DescribeSnapshots(ctx context.Context, name, clusterName, snapshotType, source string) ([]*Snapshot, error)

+ func (b *InMemoryBackend) DescribeSubnetGroups(ctx context.Context, name string) ([]*SubnetGroup, error)

+ func (b *InMemoryBackend) DescribeUsers(ctx context.Context, name string) ([]*User, error)

+ func (b *InMemoryBackend) ExportSnapshot(ctx context.Context, req *exportSnapshotRequest) (*Snapshot, error)

+ func (b *InMemoryBackend) FailoverShard(ctx context.Context, clusterName, shardName string) (*Cluster, error)

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

+ func (b *InMemoryBackend) ListAllowedNodeTypeUpdates(ctx context.Context, clusterName string) ([]string, error)

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

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

+ func (b *InMemoryBackend) PurchaseReservedNodesOffering(ctx context.Context, req *purchaseReservedNodesOfferingRequest) (*ReservedNode, error)

+ func (b *InMemoryBackend) Purge(ctx context.Context, cutoff time.Time)

+ func (b *InMemoryBackend) Region() string

+ func (b *InMemoryBackend) Reset()

+ func (b *InMemoryBackend) ResetParameterGroup(ctx context.Context, name string, parameterNames []string, allParameters bool) (*ParameterGroup, error)

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

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

+ func (b *InMemoryBackend) TagResource(_ context.Context, resourceArn string, tags map[string]string) error

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

+ func (b *InMemoryBackend) UpdateACL(ctx context.Context, req *updateACLRequest) (*ACL, error)

+ func (b *InMemoryBackend) UpdateCluster(ctx context.Context, req *updateClusterRequest) (*Cluster, error)

+ func (b *InMemoryBackend) UpdateMultiRegionCluster(_ context.Context, req *updateMultiRegionClusterRequest) (*MultiRegionCluster, error)

+ func (b *InMemoryBackend) UpdateParameterGroup(ctx context.Context, req *updateParameterGroupRequest) (*ParameterGroup, error)

+ func (b *InMemoryBackend) UpdateSubnetGroup(ctx context.Context, req *updateSubnetGroupRequest) (*SubnetGroup, error)

+ func (b *InMemoryBackend) UpdateUser(ctx context.Context, req *updateUserRequest) (*User, error)

+ type MultiRegionCluster struct

+ ARN string

+ CreatedAt time.Time

+ Description string

+ Engine string

+ EngineVersion string

+ MultiRegionClusterName string

+ MultiRegionParameterGroupName string

+ NodeType string

+ Status string

+ Tags map[string]string

+ type MultiRegionParameterGroup struct

+ ARN string

+ CreatedAt time.Time

+ Description string

+ Family string

+ Name string

+ Parameters map[string]string

+ Tags map[string]string

+ type ParameterGroup struct

+ ARN string

+ CreatedAt time.Time

+ Description string

+ Family string

+ Name string

+ Parameters map[string]string

+ Tags map[string]string

+ type Provider struct

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

+ func (p *Provider) Name() string

+ type ReservedNode struct

+ ARN string

+ Duration int32

+ FixedPrice float64

+ NodeCount int32

+ NodeType string

+ OfferingType string

+ RecurringCharges []recurringChargeObject

+ ReservationID string

+ ReservedNodeID string

+ StartTime float64

+ State string

+ UsagePrice float64

+ type ReservedNodesOffering struct

+ Duration int32

+ FixedPrice float64

+ NodeType string

+ OfferingType string

+ RecurringCharges []recurringChargeObject

+ ReservedNodesOfferingID string

+ UsagePrice float64

+ type ServiceUpdate struct

+ AutoUpdateStartDate time.Time

+ Description string

+ ReleaseDate time.Time

+ ServiceUpdateName string

+ Status string

+ Type string

+ type Snapshot struct

+ ARN string

+ ClusterConfiguration snapshotClusterConfig

+ ClusterName string

+ CreatedAt time.Time

+ KmsKeyID string

+ Name string

+ SnapshotType string

+ Source string

+ Status string

+ Tags map[string]string

+ type StorageBackend interface

+ BatchUpdateCluster func(ctx context.Context, clusterNames []string) map[string]*Cluster

+ CopySnapshot func(ctx context.Context, req *copySnapshotRequest) (*Snapshot, error)

+ CreateACL func(ctx context.Context, req *createACLRequest) (*ACL, error)

+ CreateCluster func(ctx context.Context, req *createClusterRequest) (*Cluster, error)

+ CreateMultiRegionCluster func(ctx context.Context, req *createMultiRegionClusterRequest) (*MultiRegionCluster, error)

+ CreateParameterGroup func(ctx context.Context, req *createParameterGroupRequest) (*ParameterGroup, error)

+ CreateSnapshot func(ctx context.Context, req *createSnapshotRequest) (*Snapshot, error)

+ CreateSubnetGroup func(ctx context.Context, req *createSubnetGroupRequest) (*SubnetGroup, error)

+ CreateUser func(ctx context.Context, req *createUserRequest) (*User, error)

+ DeleteACL func(ctx context.Context, name string) (*ACL, error)

+ DeleteCluster func(ctx context.Context, name string) (*Cluster, error)

+ DeleteClusterWithSnapshot func(ctx context.Context, clusterName, snapshotName string) (*Cluster, error)

+ DeleteMultiRegionCluster func(ctx context.Context, name string) (*MultiRegionCluster, error)

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

+ DeleteSnapshot func(ctx context.Context, name string) (*Snapshot, error)

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

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

+ DescribeACLs func(ctx context.Context, name string) ([]*ACL, error)

+ DescribeClusters func(ctx context.Context, name string) ([]*Cluster, error)

+ DescribeEngineVersions func(ctx context.Context, req *describeEngineVersionsRequest) ([]*EngineVersion, error)

+ DescribeEvents func(ctx context.Context, req *describeEventsRequest) ([]*Event, error)

+ DescribeMultiRegionClusters func(ctx context.Context, name string) ([]*MultiRegionCluster, error)

+ DescribeMultiRegionParameterGroups func(ctx context.Context, name string) ([]*MultiRegionParameterGroup, error)

+ DescribeMultiRegionParameters func(ctx context.Context, parameterGroupName string) (map[string]string, error)

+ DescribeParameterGroups func(ctx context.Context, name string) ([]*ParameterGroup, error)

+ DescribeParameters func(ctx context.Context, parameterGroupName string) (map[string]string, error)

+ DescribeReservedNodes func(ctx context.Context, req *describeReservedNodesRequest) ([]*ReservedNode, error)

+ DescribeReservedNodesOfferings func(ctx context.Context, req *describeReservedNodesOfferingsRequest) ([]*ReservedNodesOffering, error)

+ DescribeServiceUpdates func(ctx context.Context, req *describeServiceUpdatesRequest) ([]*ServiceUpdate, error)

+ DescribeSnapshots func(ctx context.Context, name, clusterName, snapshotType, source string) ([]*Snapshot, error)

+ DescribeSubnetGroups func(ctx context.Context, name string) ([]*SubnetGroup, error)

+ DescribeUsers func(ctx context.Context, name string) ([]*User, error)

+ ExportSnapshot func(ctx context.Context, req *exportSnapshotRequest) (*Snapshot, error)

+ FailoverShard func(ctx context.Context, clusterName, shardConfiguration string) (*Cluster, error)

+ ListAllowedMultiRegionClusterUpdates func(ctx context.Context, clusterName string) ([]string, error)

+ ListAllowedNodeTypeUpdates func(ctx context.Context, clusterName string) ([]string, error)

+ ListTags func(ctx context.Context, resourceArn string) (map[string]string, error)

+ PurchaseReservedNodesOffering func(ctx context.Context, req *purchaseReservedNodesOfferingRequest) (*ReservedNode, error)

+ Region func() string

+ Reset func()

+ ResetParameterGroup func(ctx context.Context, name string, parameterNames []string, allParameters bool) (*ParameterGroup, error)

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

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

+ TagResource func(ctx context.Context, resourceArn string, tags map[string]string) error

+ UntagResource func(ctx context.Context, resourceArn string, tagKeys []string) error

+ UpdateACL func(ctx context.Context, req *updateACLRequest) (*ACL, error)

+ UpdateCluster func(ctx context.Context, req *updateClusterRequest) (*Cluster, error)

+ UpdateMultiRegionCluster func(ctx context.Context, req *updateMultiRegionClusterRequest) (*MultiRegionCluster, error)

+ UpdateParameterGroup func(ctx context.Context, req *updateParameterGroupRequest) (*ParameterGroup, error)

+ UpdateSubnetGroup func(ctx context.Context, req *updateSubnetGroupRequest) (*SubnetGroup, error)

+ UpdateUser func(ctx context.Context, req *updateUserRequest) (*User, error)

+ type SubnetGroup struct

+ ARN string

+ CreatedAt time.Time

+ Description string

+ Name string

+ SubnetIDs []string

+ Tags map[string]string

+ VPCID string

+ type User struct

+ ARN string

+ AccessString string

+ AuthType string

+ CreatedAt time.Time

+ Engine string

+ Name string

+ Passwords []string

+ Status string

+ Tags map[string]string

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