vshnpostgres

Documentation

Index

• Constants
• func AddConnectionDetails(ctx context.Context, svc *runtime.ServiceRuntime) *v1beta1.Result
• func AddExtensions(ctx context.Context, svc *runtime.ServiceRuntime) *xfnproto.Result
• func AddLoadBalancerIPToConnectionDetails(ctx context.Context, svc *runtime.ServiceRuntime) *xfnproto.Result
• func AddPvcSecret(ctx context.Context, svc *runtime.ServiceRuntime) *xfnproto.Result
• func ConfigureReplication(ctx context.Context, svc *runtime.ServiceRuntime) *xfnproto.Result
• func DelayClusterDeployment(_ context.Context, svc *runtime.ServiceRuntime) *xfnproto.Result
• func DeployPostgreSQL(ctx context.Context, svc *runtime.ServiceRuntime) *xfnproto.Result
• func EnsureObjectBucketLabels(ctx context.Context, svc *runtime.ServiceRuntime) *xfnproto.Result
• func PgExporterConfig(ctx context.Context, svc *runtime.ServiceRuntime) *v1beta1.Result
• func TransformRestart(ctx context.Context, svc *runtime.ServiceRuntime) *xfnproto.Result
• func TransformSchedule(ctx context.Context, svc *runtime.ServiceRuntime) *xfnproto.Result

Constants

const (
	// PostgresqlHost is env variable in the connection secret
	PostgresqlHost = "POSTGRESQL_HOST"
	// PostgresqlUser is env variable in the connection secret
	PostgresqlUser = "POSTGRESQL_USER"
	// PostgresqlPassword is env variable in the connection secret
	PostgresqlPassword = "POSTGRESQL_PASSWORD"
	// PostgresqlPort is env variable in the connection secret
	PostgresqlPort = "POSTGRESQL_PORT"
	// PostgresqlDb is env variable in the connection secret
	PostgresqlDb = "POSTGRESQL_DB"
	// PostgresqlURL is env variable in the connection secret
	PostgresqlURL = "POSTGRESQL_URL"
)

Functions

func AddConnectionDetails

func AddConnectionDetails(ctx context.Context, svc *runtime.ServiceRuntime) *v1beta1.Result

AddConnectionDetails changes the desired state of a FunctionIO

func AddExtensions

func AddExtensions(ctx context.Context, svc *runtime.ServiceRuntime) *xfnproto.Result

AddExtensions adds the user specified extensions to the SGCluster.

func AddLoadBalancerIPToConnectionDetails

func AddLoadBalancerIPToConnectionDetails(ctx context.Context, svc *runtime.ServiceRuntime) *xfnproto.Result

func AddPvcSecret

func AddPvcSecret(ctx context.Context, svc *runtime.ServiceRuntime) *xfnproto.Result

AddPvcSecret adds a secret for the encrypted PVC for the PostgreSQL instance.

func ConfigureReplication

func ConfigureReplication(ctx context.Context, svc *runtime.ServiceRuntime) *xfnproto.Result

ConfigureReplication configures the stackgres replication based on the claim

func DelayClusterDeployment

func DelayClusterDeployment(_ context.Context, svc *runtime.ServiceRuntime) *xfnproto.Result

DelayClusterDeployment adds the dependencies on the sgcluster object, so that the provider-kubernetes doesn't loop anymore. The actual cluster object will only be deployed once the dependencies are deployed, synced and ready.

func DeployPostgreSQL

func DeployPostgreSQL(ctx context.Context, svc *runtime.ServiceRuntime) *xfnproto.Result

func EnsureObjectBucketLabels

func EnsureObjectBucketLabels(ctx context.Context, svc *runtime.ServiceRuntime) *xfnproto.Result

EnsureObjectBucketLabels just gets the bucket present from the PnT part and adds it again to the desired state. This ensures that the correct labels are injected.

func PgExporterConfig

func PgExporterConfig(ctx context.Context, svc *runtime.ServiceRuntime) *v1beta1.Result

func TransformRestart

func TransformRestart(ctx context.Context, svc *runtime.ServiceRuntime) *xfnproto.Result

TransformRestart triggers a restart of the postgreqsql instance if there is a pending restart and the composite is configured to restart on update.

func TransformSchedule

func TransformSchedule(ctx context.Context, svc *runtime.ServiceRuntime) *xfnproto.Result

TransformSchedule initializes the backup and maintenance schedules if the user did not explicitly provide a schedule.