persistence

Documentation

Index

• Constants
• func ConfigurePersistence(serviceContainer *corev1.Container, config *operatorapi.PersistenceOptionsSpec, ...) *corev1.Container
• func ConfigurePostgreSQLEnv(postgresql *operatorapi.PersistencePostgreSQL, ...) []corev1.EnvVar
• func GetPostgreSQLExtensions() []cfg.GroupArtifactId
• func GetPostgreSQLWorkflowProperties(workflow *operatorapi.SonataFlow) *properties.Properties
• func ResolveWorkflowPersistenceProperties(workflow *operatorapi.SonataFlow, platform *operatorapi.SonataFlowPlatform) (*properties.Properties, error)
• func RetrieveConfiguration(primary *v1alpha08.PersistenceOptionsSpec, ...) *v1alpha08.PersistenceOptionsSpec
• func RetrievePostgreSQLConfiguration(primary *v1alpha08.PersistenceOptionsSpec, ...) *v1alpha08.PersistenceOptionsSpec
• func UsesPostgreSQLPersistence(workflow *operatorapi.SonataFlow, platform *operatorapi.SonataFlowPlatform) bool

Constants

const (
	QuarkusFlywayMigrateAtStart         string = "quarkus.flyway.migrate-at-start"
	QuarkusDatasourceDBKind             string = "quarkus.datasource.db-kind"
	QuarkusDatasourceJDBCURL            string = "quarkus.datasource.jdbc.url"
	KogitoPersistenceType               string = "kogito.persistence.type"
	JDBCPersistenceType                 string = "jdbc"
	KogitoPersistenceQueryTimeoutMillis string = "kogito.persistence.query.timeout.millis"
	KogitoPersistenceProtoMarshaller    string = "kogito.persistence.proto.marshaller"
	PostgreSQLDBKind                    string = "postgresql"
)

Functions

func ConfigurePersistence

func ConfigurePersistence(serviceContainer *corev1.Container, config *operatorapi.PersistenceOptionsSpec, defaultSchema, namespace string) *corev1.Container

func ConfigurePostgreSQLEnv

func ConfigurePostgreSQLEnv(postgresql *operatorapi.PersistencePostgreSQL, databaseSchema, databaseNamespace string) []corev1.EnvVar

ConfigurePostgreSQLEnv returns the common env variables required for the DataIndex or JobsService when postresql persistence is used.

func GetPostgreSQLExtensions

func GetPostgreSQLExtensions() []cfg.GroupArtifactId

GetPostgreSQLExtensions returns the Quarkus extensions required for postgresql persistence.

func GetPostgreSQLWorkflowProperties

func GetPostgreSQLWorkflowProperties(workflow *operatorapi.SonataFlow) *properties.Properties

GetPostgreSQLWorkflowProperties returns the set of application properties required for postgresql persistence. Never nil.

func ResolveWorkflowPersistenceProperties

func ResolveWorkflowPersistenceProperties(workflow *operatorapi.SonataFlow, platform *operatorapi.SonataFlowPlatform) (*properties.Properties, error)

ResolveWorkflowPersistenceProperties returns the set of application properties required for the workflow persistence. Never nil.

func RetrieveConfiguration

func RetrieveConfiguration(primary *v1alpha08.PersistenceOptionsSpec, platformPersistence *v1alpha08.PlatformPersistenceOptionsSpec, schema string) *v1alpha08.PersistenceOptionsSpec

func RetrievePostgreSQLConfiguration

func RetrievePostgreSQLConfiguration(primary *v1alpha08.PersistenceOptionsSpec, platformPersistence *v1alpha08.PlatformPersistenceOptionsSpec, schema string) *v1alpha08.PersistenceOptionsSpec

RetrievePostgreSQLConfiguration return the PersistenceOptionsSpec considering that postgresql is the database manager to look for. Gives priority to the primary configuration.

func UsesPostgreSQLPersistence

func UsesPostgreSQLPersistence(workflow *operatorapi.SonataFlow, platform *operatorapi.SonataFlowPlatform) bool