Documentation ¶
Index ¶
- Constants
- func AutoDiscoverPostgresVersionFromImage(image string) (string, error)
- func RetryAllErrorsFn(ctx context.Context) func(err error) bool
- func RunPGDataMigration(ctx context.Context, k8sClient *kubernetes.Clientset, ...) error
- func Truncate(s string, n int) string
- type JobActions
- type PGUpgradeRunner
- type PGUpgradeSettings
Constants ¶
View Source
const ( PostHookScriptFileName = "posthook.sh" PrepareScriptFileName = "prepare.sh" )
View Source
const (
DefaultPostgresInitDBUser = "postgres"
)
Variables ¶
This section is empty.
Functions ¶
func RunPGDataMigration ¶
func RunPGDataMigration(ctx context.Context, k8sClient *kubernetes.Clientset, namespace, sourcePersistenVolumeName, targetPVCName, storageClassName string, newSize string, jobaction JobActions) error
Types ¶
type JobActions ¶
type PGUpgradeRunner ¶
type PGUpgradeRunner struct {
// contains filtered or unexported fields
}
func NewPGUpgradeRunner ¶
func NewPGUpgradeRunner(namespace string, settings PGUpgradeSettings) (*PGUpgradeRunner, error)
func (*PGUpgradeRunner) RunPGUpgradeForDatabasePVC ¶
func (r *PGUpgradeRunner) RunPGUpgradeForDatabasePVC(ctx context.Context) error
func (*PGUpgradeRunner) RunPGUpgradeForDatabaseStatefulSet ¶
func (r *PGUpgradeRunner) RunPGUpgradeForDatabaseStatefulSet(ctx context.Context, targetStatefulSetName string) error
type PGUpgradeSettings ¶
type PGUpgradeSettings struct { UpgradeImage string InitDBArgs string DiskSize string CurrentPostgresVersion string TargetPostgresVersion string PostgresContainerName string PVCName string InitDBUser string SourcePVCName string TargetPVCName string SubPath string }
func (*PGUpgradeSettings) GetInitDBUser ¶
func (s *PGUpgradeSettings) GetInitDBUser() string
func (*PGUpgradeSettings) GetUpgradeImage ¶
func (s *PGUpgradeSettings) GetUpgradeImage() string
func (*PGUpgradeSettings) Validate ¶
func (s *PGUpgradeSettings) Validate() error
Click to show internal directories.
Click to hide internal directories.