Method PromoteAndWait

pkg/management/postgres/promote.go:35–94

PromoteAndWait promotes this instance, and wait DefaultPgCtlTimeoutForPromotion seconds for it to happen

(ctx context.Context)

// PromoteAndWait promotes this instance, and wait DefaultPgCtlTimeoutForPromotion
// seconds for it to happen
func (instance *Instance) PromoteAndWait(ctx context.Context) error {
	contextLogger := log.FromContext(ctx)

	instance.ShutdownConnections()

	instance.LogPgControldata(ctx, "promote")

	options := []string{
		"-D",
		instance.PgData,
		"-w",
		"promote",
		"-t " + strconv.Itoa(int(instance.GetClusterOrDefault().GetPgCtlTimeoutForPromotion())),
	}

	contextLogger.Info("Promoting instance", "pgctl_options", options)

	pgCtlCmd := exec.Command(pgCtlName, options...) // #nosec
	err := execlog.RunStreaming(pgCtlCmd, pgCtlName)
	if err != nil {
		return fmt.Errorf("error promoting the PostgreSQL instance: %w", err)
	}

	timeLimit := time.Now().Add(1 * time.Minute)
	for {
		if time.Now().After(timeLimit) {
			contextLogger.Info("The standby.signal file still exists but timeout reached, " +
				"error during PostgreSQL instance promotion")
			return fmt.Errorf("standby.signal still existent")
		}

		if status, _ := instance.IsPrimary(); status {
			break
		}

		time.Sleep(1 * time.Second)
	}

	contextLogger.Info("Requesting a checkpoint")

	db, err := instance.GetSuperUserDB()
	if err != nil {
		return fmt.Errorf("after having promoted the instance: %v", err)
	}

	err = db.Ping()
	if err != nil {
		return fmt.Errorf("after having promoted the instance: %v", err)
	}

	// For pg_rewind to work we need to issue a checkpoint here
	_, err = db.Exec("CHECKPOINT")
	if err != nil {
		return fmt.Errorf("checkpoint after instance promotion: %v", err)
	}

	contextLogger.Info("The PostgreSQL instance has been promoted successfully")