aws_postgres

Documentation

Index

• type DBLite
• type DBMigrator
  • func NewDBMigrator(client SecretsManagerAPI, creds RDSAuthProvider) *DBMigrator
  • func (d *DBMigrator) CleanupPostgresDatabase(ctx context.Context, migrationID string, ...) error
  • func (d *DBMigrator) DestroyPostgresDatabase(ctx context.Context, migrationID string, ...) error
  • func (d *DBMigrator) UpsertPostgresDatabase(ctx context.Context, migrationID string, ...) error
• type DBSecret
• type DBSpec
• type IDBMigrator
• type PostgresMigrateWorker
  • func NewPostgresMigrateWorker(db DBLite, migrator IDBMigrator) *PostgresMigrateWorker
  • func (d *PostgresMigrateWorker) CleanupPostgresDatabase(ctx context.Context, msg *awsinfra_tpb.CleanupPostgresDatabaseMessage) (*emptypb.Empty, error)
  • func (d *PostgresMigrateWorker) DestroyPostgresDatabase(ctx context.Context, msg *awsinfra_tpb.DestroyPostgresDatabaseMessage) (*emptypb.Empty, error)
  • func (d *PostgresMigrateWorker) UpsertPostgresDatabase(ctx context.Context, msg *awsinfra_tpb.UpsertPostgresDatabaseMessage) (*emptypb.Empty, error)
• type RDSAuthProvider
• type SecretsManagerAPI

Types

type DBLite

type DBLite interface {
	PublishEvent(context.Context, o5msg.Message) error
	RequestToClientToken(context.Context, *messaging_j5pb.RequestMetadata) (string, error)
	ClientTokenToRequest(context.Context, string) (*messaging_j5pb.RequestMetadata, error)
}

type DBMigrator

type DBMigrator struct {
	// contains filtered or unexported fields
}

func NewDBMigrator

func NewDBMigrator(client SecretsManagerAPI, creds RDSAuthProvider) *DBMigrator

func (*DBMigrator) CleanupPostgresDatabase

func (d *DBMigrator) CleanupPostgresDatabase(ctx context.Context, migrationID string, msg *awsinfra_tpb.CleanupPostgresDatabaseMessage) error

func (*DBMigrator) DestroyPostgresDatabase

func (d *DBMigrator) DestroyPostgresDatabase(ctx context.Context, migrationID string, msg *awsinfra_tpb.DestroyPostgresDatabaseMessage) error

func (*DBMigrator) UpsertPostgresDatabase

func (d *DBMigrator) UpsertPostgresDatabase(ctx context.Context, migrationID string, msg *awsinfra_tpb.UpsertPostgresDatabaseMessage) error

type DBSecret

type DBSecret struct {
	Username string `json:"dbuser"`
	Password string `json:"dbpass"`
	Hostname string `json:"dbhost"`
	DBName   string `json:"dbname"`
	URL      string `json:"dburl"`
}

type DBSpec

type DBSpec interface {
	OpenRoot(context.Context) (*sql.DB, error)
	OpenDBAsRoot(ctx context.Context, dbName string) (*sql.DB, error)

	// NewAppSecret creates the APP side secret for either root connection type.
	NewAppSecret(dbName string) DBSecret
}

type IDBMigrator

type IDBMigrator interface {
	UpsertPostgresDatabase(ctx context.Context, migrationID string, msg *awsinfra_tpb.UpsertPostgresDatabaseMessage) error
	CleanupPostgresDatabase(ctx context.Context, migrationID string, msg *awsinfra_tpb.CleanupPostgresDatabaseMessage) error
	DestroyPostgresDatabase(ctx context.Context, migrationID string, msg *awsinfra_tpb.DestroyPostgresDatabaseMessage) error
}

type PostgresMigrateWorker

type PostgresMigrateWorker struct {
	awsinfra_tpb.UnimplementedPostgresRequestTopicServer
	// contains filtered or unexported fields
}

func NewPostgresMigrateWorker

func NewPostgresMigrateWorker(db DBLite, migrator IDBMigrator) *PostgresMigrateWorker

func (*PostgresMigrateWorker) CleanupPostgresDatabase

func (d *PostgresMigrateWorker) CleanupPostgresDatabase(ctx context.Context, msg *awsinfra_tpb.CleanupPostgresDatabaseMessage) (*emptypb.Empty, error)

func (*PostgresMigrateWorker) DestroyPostgresDatabase

func (d *PostgresMigrateWorker) DestroyPostgresDatabase(ctx context.Context, msg *awsinfra_tpb.DestroyPostgresDatabaseMessage) (*emptypb.Empty, error)

func (*PostgresMigrateWorker) UpsertPostgresDatabase

func (d *PostgresMigrateWorker) UpsertPostgresDatabase(ctx context.Context, msg *awsinfra_tpb.UpsertPostgresDatabaseMessage) (*emptypb.Empty, error)

type RDSAuthProvider

type RDSAuthProvider interface {
	BuildAuthToken(ctx context.Context, dbEndpoint, dbUser string) (string, error)
}

type SecretsManagerAPI

type SecretsManagerAPI interface {
	GetSecretValue(ctx context.Context, params *secretsmanager.GetSecretValueInput, optFns ...func(*secretsmanager.Options)) (*secretsmanager.GetSecretValueOutput, error)
	UpdateSecret(ctx context.Context, params *secretsmanager.UpdateSecretInput, optFns ...func(*secretsmanager.Options)) (*secretsmanager.UpdateSecretOutput, error)
	DescribeSecret(ctx context.Context, params *secretsmanager.DescribeSecretInput, optFns ...func(*secretsmanager.Options)) (*secretsmanager.DescribeSecretOutput, error)
}