controllers

package
v0.17.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 24, 2024 License: AGPL-3.0 Imports: 41 Imported by: 0

Documentation

Overview

/ SPDX-FileCopyrightText: 2021 Finanz Informatik Technologie Services GmbHs / / SPDX-License-Identifier: AGPL-1.0-only

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type PatroniConfig added in v0.15.0

type PatroniConfig struct {
	StandbyCluster             *PatroniStandbyCluster `json:"standby_cluster"`
	SynchronousNodesAdditional *string                `json:"synchronous_nodes_additional"`
}

type PatroniStandbyCluster added in v0.15.0

type PatroniStandbyCluster struct {
	CreateReplicaMethods []string `json:"create_replica_methods"`
	Host                 string   `json:"host"`
	Port                 int      `json:"port"`
	ApplicationName      string   `json:"application_name"`
}

type PostgresReconciler

type PostgresReconciler struct {
	CtrlClient                        client.Client
	SvcClient                         client.Client
	Log                               logr.Logger
	Scheme                            *runtime.Scheme
	PartitionID, Tenant, StorageClass string
	*operatormanager.OperatorManager
	*lbmanager.LBManager

	PgParamBlockList                    map[string]bool
	StandbyClustersSourceRanges         []string
	PostgresletNamespace                string
	SidecarsConfigMapName               string
	EnableNetPol                        bool
	EtcdHost                            string
	PatroniTTL                          uint32
	PatroniLoopWait                     uint32
	PatroniRetryTimeout                 uint32
	ReplicationChangeRequeueDuration    time.Duration
	EnableRandomStorageEncryptionSecret bool
	EnableWalGEncryption                bool
	PostgresletFullname                 string
	PostgresImage                       string
	InitDBJobConfigMapName              string
	EnableBootstrapStandbyFromS3        bool
	EnableSuperUserForDBO               bool
	EnableCustomTLSCert                 bool
	TLSClusterIssuer                    string
	TLSSubDomain                        string
	// contains filtered or unexported fields
}

PostgresReconciler reconciles a Postgres object

func (*PostgresReconciler) Reconcile

func (r *PostgresReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is the entry point for postgres reconciliation. +kubebuilder:rbac:groups=database.fits.cloud,resources=postgres,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=database.fits.cloud,resources=postgres/status,verbs=get;update;patch +kubebuilder:rbac:groups=acid.zalan.do,resources=postgresqls,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=acid.zalan.do,resources=postgresqls/status,verbs=get;list;watch

func (*PostgresReconciler) SetupWithManager

func (r *PostgresReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager informs mgr when this reconciler should be called.

type StatusReconciler

type StatusReconciler struct {
	SvcClient             client.Client
	CtrlClient            client.Client
	Log                   logr.Logger
	Scheme                *runtime.Scheme
	PartitionID           string
	ControlPlaneNamespace string
	EnableForceSharedIP   bool
}

StatusReconciler reconciles a Postgresql object

func (*StatusReconciler) Reconcile

func (r *StatusReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile updates the status of the remote Postgres object based on the status of the local zalando object. +kubebuilder:rbac:groups=acid.zalan.do,resources=postgresqls,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=acid.zalan.do,resources=postgresqls/status,verbs=get;update;patch

func (*StatusReconciler) SetupWithManager

func (r *StatusReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager registers this controller for reconciliation of Postgresql resources

Jump to

Keyboard shortcuts

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