Method createConnectionPooler

pkg/cluster/connection_pooler.go:159–168

Prepare the database for connection pooler to be used, i.e. install lookup function (do it first, because it should be fast and if it didn't succeed, it doesn't makes sense to create more K8S objects. At this moment we assume that necessary connection pooler user exists. After that create all the o

(LookupFunction InstallFunction)

// add these cp related functions to a new cp file
// opConfig, cluster, and database name
func (c *Cluster) createConnectionPooler(LookupFunction InstallFunction) (SyncReason, error) {
	var reason SyncReason
	c.setProcessName("creating connection pooler")

	//this is essentially sync with nil as oldSpec
	if reason, err := c.syncConnectionPooler(&acidv1.Postgresql{}, &c.Postgresql, LookupFunction); err != nil {
		return reason, err
	}
	return reason, nil
}

// Generate pool size related environment variables.
//