databases

Documentation

Index

• Constants
• func Create(ctx core.Context, stack *v1beta1.Stack, owner interface{ ... }) (*v1beta1.Database, error)
• func Delete(ctx core.Context, database *v1beta1.Database) error
• func GetPostgresEnvVars(ctx core.Context, stack *v1beta1.Stack, db *v1beta1.Database) ([]corev1.EnvVar, error)
• func GetSavedModuleVersion(database *v1beta1.Database) string
• func Migrate(ctx core.Context, stack *v1beta1.Stack, image string, ...) error
• func MigrateDatabaseContainer(ctx core.Context, stack *v1beta1.Stack, image string, ...) (v1.Container, error)
• func PostgresEnvVarsWithPrefix(ctx core.Context, stack *v1beta1.Stack, database *v1beta1.Database, ...) ([]corev1.EnvVar, error)
• func Reconcile(ctx core.Context, stack *v1beta1.Stack, database *v1beta1.Database) error
• func SaveModuleVersion(ctx core.Context, database *v1beta1.Database, version string) error
• func Watch[T client.Object]() core.ReconcilerOption[T]
• type MigrationConfiguration

Constants

const ServiceVersion = "formance.com/module-version"

Functions

func Create

func Create(ctx core.Context, stack *v1beta1.Stack, owner interface {
	v1beta1.Object
	IsDebug() bool
}) (*v1beta1.Database, error)

func Delete

func Delete(ctx core.Context, database *v1beta1.Database) error

func GetPostgresEnvVars

func GetPostgresEnvVars(ctx core.Context, stack *v1beta1.Stack, db *v1beta1.Database) ([]corev1.EnvVar, error)

func GetSavedModuleVersion

func GetSavedModuleVersion(database *v1beta1.Database) string

func Migrate

func Migrate(ctx core.Context, stack *v1beta1.Stack, image string, database *v1beta1.Database, options ...func(m *MigrationConfiguration)) error

func MigrateDatabaseContainer

func MigrateDatabaseContainer(ctx core.Context, stack *v1beta1.Stack, image string, database *v1beta1.Database, options ...func(m *MigrationConfiguration)) (v1.Container, error)

func PostgresEnvVarsWithPrefix

func PostgresEnvVarsWithPrefix(ctx core.Context, stack *v1beta1.Stack, database *v1beta1.Database, prefix string) ([]corev1.EnvVar, error)

func Reconcile

func Reconcile(ctx core.Context, stack *v1beta1.Stack, database *v1beta1.Database) error

func SaveModuleVersion

func SaveModuleVersion(ctx core.Context, database *v1beta1.Database, version string) error

func Watch

func Watch[T client.Object]() core.ReconcilerOption[T]

Types

type MigrationConfiguration

type MigrationConfiguration struct {
	Command       []string
	AdditionalEnv []v1.EnvVar
}