configmap

package

v0.0.0-...-db6441f Latest Latest Go to latest Published: Sep 3, 2025 License: BSD-2-Clause Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/k-web-s/patroni-postgres-operator

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func ClearUpgradeAnnotations(ctx context.Context, p *v1alpha1.PatroniPostgres) (err error)
func GetDBId(ctx context.Context, p *v1alpha1.PatroniPostgres) (dbid string, err error)
func GetPrimaryInitdbArgs(ctx context.Context, p *v1alpha1.PatroniPostgres) (args string, err error)
func GetSecondaryStreamArgs(ctx context.Context, p *v1alpha1.PatroniPostgres) (LatestCheckpointLocation string, NewDBSystemId string, err error)
func GetSyncLeader(ctx context.Context, p *v1alpha1.PatroniPostgres) (index int, err error)
func Reconcile(ctx context.Context, p *v1alpha1.PatroniPostgres) (err error)
func SetDBId(ctx context.Context, p *v1alpha1.PatroniPostgres, dbid string) (err error)
func SetLatestCheckpointLocation(ctx context.Context, p *v1alpha1.PatroniPostgres, ...) (err error)
func SetPrimaryInitdbArgs(ctx context.Context, p *v1alpha1.PatroniPostgres, args string) (err error)

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrNoDBIDfound                     = errors.New("no Database system identifier found")
	ErrNoLatestCheckpointLocationFound = errors.New("no Latest Checkpoint Location found")
	ErrNoSyncLeader                    = errors.New("no sync leader found")
	ErrNoConfigAnnotation              = errors.New("no config annotation found")
)

Functions ¶

func ClearUpgradeAnnotations ¶

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

func GetDBId ¶

func GetDBId(ctx context.Context, p *v1alpha1.PatroniPostgres) (dbid string, err error)

func GetPrimaryInitdbArgs ¶

func GetPrimaryInitdbArgs(ctx context.Context, p *v1alpha1.PatroniPostgres) (args string, err error)

func GetSecondaryStreamArgs ¶

func GetSecondaryStreamArgs(ctx context.Context, p *v1alpha1.PatroniPostgres) (LatestCheckpointLocation string, NewDBSystemId string, err error)

func GetSyncLeader ¶

func GetSyncLeader(ctx context.Context, p *v1alpha1.PatroniPostgres) (index int, err error)

func Reconcile ¶

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

func SetDBId ¶

func SetDBId(ctx context.Context, p *v1alpha1.PatroniPostgres, dbid string) (err error)

SetDBId sets Database system identifier after an upgrade, and resumes Patroni

func SetLatestCheckpointLocation ¶

func SetLatestCheckpointLocation(ctx context.Context, p *v1alpha1.PatroniPostgres, LatestCheckpointLocation string) (err error)

func SetPrimaryInitdbArgs ¶

func SetPrimaryInitdbArgs(ctx context.Context, p *v1alpha1.PatroniPostgres, args string) (err error)

Types ¶

This section is empty.

Source Files ¶

View all Source files

configmap.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL