statefulset

Documentation

Index

• Constants
• func GetK8SStatefulSet(ctx context.Context, p *v1alpha1.PatroniPostgres) (sts *appsv1.StatefulSet, err error)
• func Reconcile(ctx context.Context, p *v1alpha1.PatroniPostgres) (err error)
• func ReconcileSts(ctx context.Context, p *v1alpha1.PatroniPostgres, patches ...Patch) (sts *appsv1.StatefulSet, err error)
• type Patch
  • func WithPausedPatroni(p *v1alpha1.PatroniPostgres) Patch
  • func WithPostgresqlPort(port int) Patch

Constants

const (
	Image = "ghcr.io/rkojedzinszky/postgres-patroni:20250114"

	PatroniSuperuserUsername = "postgres"

	DataVolumeMountPath = "/var/lib/postgresql"
)

Functions

func GetK8SStatefulSet

func GetK8SStatefulSet(ctx context.Context, p *v1alpha1.PatroniPostgres) (sts *appsv1.StatefulSet, err error)

func Reconcile

func Reconcile(ctx context.Context, p *v1alpha1.PatroniPostgres) (err error)

func ReconcileSts

func ReconcileSts(ctx context.Context, p *v1alpha1.PatroniPostgres, patches ...Patch) (sts *appsv1.StatefulSet, err error)

Types

type Patch

type Patch interface {
	Patch(*appsv1.StatefulSet)
}

func WithPausedPatroni

func WithPausedPatroni(p *v1alpha1.PatroniPostgres) Patch

func WithPostgresqlPort

func WithPostgresqlPort(port int) Patch