Method Join

pkg/management/postgres/join.go:77–97

Join creates a new instance joined to an existing PostgreSQL cluster

(ctx context.Context, cluster *apiv1.Cluster)

// Join creates a new instance joined to an existing PostgreSQL cluster
func (info InitInfo) Join(ctx context.Context, cluster *apiv1.Cluster) error {
	primaryConnInfo := buildPrimaryConnInfo(info.ParentNode, info.PodName) + " dbname=postgres connect_timeout=5"

	// We explicitly disable wal_sender_timeout for join-related pg_basebackup executions.
	// A short timeout could not be enough in case the instance is slow to send data,
	// like when the I/O is overloaded.
	primaryConnInfo += " options='-c wal_sender_timeout=0s'"

	coredumpFilter := cluster.GetCoredumpFilter()
	if err := system.SetCoredumpFilter(coredumpFilter); err != nil {
		return err
	}

	if err := ClonePgData(ctx, primaryConnInfo, info.PgData, info.PgWal); err != nil {
		return err
	}

	slotName := cluster.GetSlotNameFromInstanceName(info.PodName)
	_, err := UpdateReplicaConfiguration(info.PgData, info.GetPrimaryConnInfo(), slotName)
	return err
}