utils

func HaveColumns ¶

func HaveColumns(
	ctx context.Context,
	schema string,
	table string,
	columns []postgresv1alpha1.PostgresColumn,
) types.GomegaMatcher

HaveColumns checks if the PostgreSQL database connected through actual has columns in the given schema and table matching the specification.

func RequestLogger ¶

func RequestLogger(ctx context.Context, baseLogger logr.Logger) logr.Logger

WithRequestLogger returns request-scoped logger from the given context.

func SetupPostgresConnection ¶

func SetupPostgresConnection(
	ctx context.Context,
	r client.Reader,
	recorder record.EventRecorder,
	ref postgresv1alpha1.PostgresRef,
	obj metav1.ObjectMeta,
) (*pgx.Conn, error)

func WithRequestLogger ¶

func WithRequestLogger(
	ctx context.Context,
	req ctrl.Request,
	resourceKind string,
	baseLogger logr.Logger,
) context.Context

WithRequestLogger returns a context that has a request-scoped logger attached to it.