redis

package

v0.0.0-...-05ec1ec Latest Latest Go to latest Published: Apr 1, 2026 License: CC0-1.0 Imports: 29 Imported by: 1

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/cloud-gov/aws-broker

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func ConvertTagsToElasticacheTags(tags map[string]string) []elasticacheTypes.Tag
func InitRedisBroker(catalog *catalog.Catalog, brokerDB *gorm.DB, settings *config.Settings, ...) (base.Broker, error)
func NewRedisDedicatedDBAdapter(s *config.Settings, db *gorm.DB, elasticache ElasticacheClientInterface, ...) *dedicatedRedisAdapter
type ElasticacheClientInterface
type RedisInstance
type RedisOptions
- func (r RedisOptions) Validate(settings *config.Settings) error

Constants ¶

View Source

const PgroupPrefix = "cg-redis-broker-"

This is the prefix for all pgroups created by the broker.

Variables ¶

This section is empty.

Functions ¶

func ConvertTagsToElasticacheTags ¶

func ConvertTagsToElasticacheTags(tags map[string]string) []elasticacheTypes.Tag

func InitRedisBroker ¶

func InitRedisBroker(
	catalog *catalog.Catalog,
	brokerDB *gorm.DB,
	settings *config.Settings,
	tagManager brokertags.TagManager,
) (base.Broker, error)

InitRedisBroker is the constructor for the redisBroker.

func NewRedisDedicatedDBAdapter ¶

func NewRedisDedicatedDBAdapter(s *config.Settings, db *gorm.DB, elasticache ElasticacheClientInterface, s3 brokerAws.S3ClientInterface, logger lager.Logger) *dedicatedRedisAdapter

Types ¶

type ElasticacheClientInterface ¶

type ElasticacheClientInterface interface {
	CopySnapshot(ctx context.Context, params *elasticache.CopySnapshotInput, optFns ...func(*elasticache.Options)) (*elasticache.CopySnapshotOutput, error)
	CreateReplicationGroup(ctx context.Context, params *elasticache.CreateReplicationGroupInput, optFns ...func(*elasticache.Options)) (*elasticache.CreateReplicationGroupOutput, error)
	DeleteReplicationGroup(ctx context.Context, params *elasticache.DeleteReplicationGroupInput, optFns ...func(*elasticache.Options)) (*elasticache.DeleteReplicationGroupOutput, error)
	DeleteSnapshot(ctx context.Context, params *elasticache.DeleteSnapshotInput, optFns ...func(*elasticache.Options)) (*elasticache.DeleteSnapshotOutput, error)
	DescribeReplicationGroups(ctx context.Context, params *elasticache.DescribeReplicationGroupsInput, optFns ...func(*elasticache.Options)) (*elasticache.DescribeReplicationGroupsOutput, error)
	DescribeSnapshots(ctx context.Context, params *elasticache.DescribeSnapshotsInput, optFns ...func(*elasticache.Options)) (*elasticache.DescribeSnapshotsOutput, error)
	IncreaseReplicaCount(ctx context.Context, params *elasticache.IncreaseReplicaCountInput, optFns ...func(*elasticache.Options)) (*elasticache.IncreaseReplicaCountOutput, error)
	ModifyReplicationGroup(ctx context.Context, params *elasticache.ModifyReplicationGroupInput, optFns ...func(*elasticache.Options)) (*elasticache.ModifyReplicationGroupOutput, error)
}

type RedisInstance ¶

type RedisInstance struct {
	base.Instance

	Description string `sql:"size(255)"`

	Password string `sql:"size(255)" deep:"-"`
	Salt     string `sql:"size(255)" deep:"-"`

	ClearPassword string `gorm:"-" deep:"-"`

	Engine                     string `sql:"size(255)"`
	EngineVersion              string `sql:"size(255)"`
	ClusterID                  string `sql:"size(255)"`
	CacheNodeType              string `sql:"size(255)"`
	NumCacheClusters           int    `sql:"size(255)"`
	ParameterGroup             string `sql:"size(255)"`
	PreferredMaintenanceWindow string `sql:"size(255)"`
	SnapshotWindow             string `sql:"size(255)"`
	SnapshotRetentionLimit     int    `sql:"size(255)"`
	AutomaticFailoverEnabled   bool   `sql:"size(255)"`

	Tags          map[string]string `gorm:"-"`
	DbSubnetGroup string            `gorm:"-"`
	SecGroup      string            `gorm:"-"`

	ParameterGroupFamily string `gorm:"-"`
	ParameterGroupName   string `sql:"size(255)"`

	EngineLogsGroupName string `sql:"size(512)"`
	SlowLogsGroupName   string `sql:"size(512)"`

	NewReplicaCount int `gorm:"-"`
}

RedisInstance represents the information of a Redis Service instance.

type RedisOptions ¶

type RedisOptions struct {
	Engine        string `json:"engine"`
	EngineVersion string `json:"engine_version"`
}

func (RedisOptions) Validate ¶

func (r RedisOptions) Validate(settings *config.Settings) error

Source Files ¶

View all Source files

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