Function newFakePooler

internal/controller/suite_test.go:139–175

(k8sClient client.Client, cluster *apiv1.Cluster)

}

func newFakePooler(k8sClient client.Client, cluster *apiv1.Cluster) *apiv1.Pooler {
	pooler := &apiv1.Pooler{
		ObjectMeta: metav1.ObjectMeta{
			Name:        "pooler-" + rand.String(10),
			Namespace:   cluster.Namespace,
			Annotations: map[string]string{},
			Labels:      map[string]string{},
		},
		Spec: apiv1.PoolerSpec{
			Cluster: apiv1.LocalObjectReference{
				Name: cluster.Name,
			},
			Type:      "rw",
			Instances: ptr.To(int32(1)),
			PgBouncer: &apiv1.PgBouncerSpec{
				PoolMode: apiv1.PgBouncerPoolModeSession,
			},
		},
		Status: apiv1.PoolerStatus{
			// Pre-populate the resolved image so unit tests that call
			// updateDeployment directly (bypassing updatePoolerStatus) start from
			// the same precondition as a fully reconciled Pooler.
			Image: configuration.Current.PgbouncerImageName,
		},
	}

	err := k8sClient.Create(context.Background(), pooler)
	Expect(err).ToNot(HaveOccurred())

	// upstream issue, go client cleans typemeta: https://github.com/kubernetes/client-go/issues/308
	pooler.TypeMeta = metav1.TypeMeta{
		Kind:       apiv1.PoolerKind,
		APIVersion: apiv1.SchemeGroupVersion.String(),
	}

	return pooler
}

func newFakeCNPGCluster(
	k8sClient client.Client,